We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 9cde4b9 commit 362afd8Copy full SHA for 362afd8
lib/change_stream.js
@@ -453,6 +453,10 @@ function processNewChange(args) {
453
454
changeStream.resumeToken = change._id;
455
456
+ // wipe the startAtOperationTime if there was one so that there won't be a conflict
457
+ // between resumeToken and startAtOperationTime if we need to reconnect the cursor
458
+ changeStream.options.startAtOperationTime = undefined;
459
+
460
// Return the change
461
if (eventEmitter) return changeStream.emit('change', change);
462
if (typeof callback === 'function') return callback(error, change);
0 commit comments