Skip to content

Commit ee93834

Browse files
add moreToCome back on the request
1 parent 6422402 commit ee93834

File tree

1 file changed

+17
-7
lines changed

1 file changed

+17
-7
lines changed

src/cmap/commands.ts

Lines changed: 17 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -50,6 +50,7 @@ export interface OpQueryOptions extends CommandOptions {
5050
secondaryOk?: boolean;
5151

5252
requestId?: number;
53+
moreToCome?: boolean;
5354
exhaustAllowed?: boolean;
5455
}
5556

@@ -408,12 +409,21 @@ const OPTS_EXHAUST_ALLOWED = 1 << 16;
408409

409410
/** @internal */
410411
export interface OpMsgOptions {
411-
requestId: number;
412-
serializeFunctions: boolean;
413-
ignoreUndefined: boolean;
414-
checkKeys: boolean;
415-
maxBsonSize: number;
416-
exhaustAllowed: boolean;
412+
socketTimeoutMS?: number;
413+
session?: ClientSession;
414+
numberToSkip?: number;
415+
numberToReturn?: number;
416+
returnFieldSelector?: Document;
417+
pre32Limit?: number;
418+
serializeFunctions?: boolean;
419+
ignoreUndefined?: boolean;
420+
maxBsonSize?: number;
421+
checkKeys?: boolean;
422+
secondaryOk?: boolean;
423+
424+
requestId?: number;
425+
moreToCome?: boolean;
426+
exhaustAllowed?: boolean;
417427
readPreference: ReadPreference;
418428
}
419429

@@ -465,7 +475,7 @@ export class OpMsgRequest {
465475

466476
// flags
467477
this.checksumPresent = false;
468-
this.moreToCome = command.writeConcern?.w === 0 || false;
478+
this.moreToCome = options.moreToCome || command.writeConcern?.w === 0 || false;
469479
this.exhaustAllowed =
470480
typeof options.exhaustAllowed === 'boolean' ? options.exhaustAllowed : false;
471481
}

0 commit comments

Comments
 (0)