Skip to content

Commit f190072

Browse files
mbroadstdaprahamian
authored andcommitted
fix(change-streams): don't copy irrelevant resume options
1 parent f6dd6c9 commit f190072

File tree

1 file changed

+8
-4
lines changed

1 file changed

+8
-4
lines changed

lib/change_stream.js

+8-4
Original file line numberDiff line numberDiff line change
@@ -272,10 +272,14 @@ class ChangeStreamCursor extends Cursor {
272272
if (this.options[optionName]) result[optionName] = this.options[optionName];
273273
}
274274

275-
if (this.resumeToken) {
276-
Object.assign(result, { resumeAfter: this.resumeToken });
277-
} else if (this.startAtOperationTime && maxWireVersion(this.server) >= 7) {
278-
Object.assign(result, { startAtOperationTime: this.startAtOperationTime });
275+
if (this.resumeToken || this.startAtOperationTime) {
276+
['resumeAfter', 'startAfter', 'startAtOperationTime'].forEach(key => delete result[key]);
277+
278+
if (this.resumeToken) {
279+
result.resumeAfter = this.resumeToken;
280+
} else if (this.startAtOperationTime && maxWireVersion(this.server) >= 7) {
281+
result.startAtOperationTime = this.startAtOperationTime;
282+
}
279283
}
280284

281285
return result;

0 commit comments

Comments
 (0)