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