fix: move maxWireVersion update to inside getMore callback

mongodb · Jun 15, 2022 · 19ebf83 · 19ebf83
1 parent 875b1c3
commit 19ebf83
Showing 1 changed file with 1 addition and 2 deletions.
diff --git 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<TChange>);
 
       this.emit(ChangeStream.MORE, response);