diff --git a/src/cursor/change_stream_cursor.ts b/src/cursor/change_stream_cursor.ts index 54c62f5006..b5a4ae4630 100644 --- a/src/cursor/change_stream_cursor.ts +++ b/src/cursor/change_stream_cursor.ts @@ -178,13 +178,12 @@ export class ChangeStreamCursor< } override _getMore(batchSize: number, callback: Callback): void { - this.maxWireVersion = maxWireVersion(this.server); - super._getMore(batchSize, (err, response) => { if (err) { return callback(err); } + this.maxWireVersion = maxWireVersion(this.server); this._processBatch(response as TODO_NODE_3286 as ChangeStreamAggregateRawResult); this.emit(ChangeStream.MORE, response);