We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 15d69c8 commit f24c084Copy full SHA for f24c084
lib/change_stream.js
@@ -405,7 +405,11 @@ function processNewChange(args) {
405
// attempt recreating the cursor
406
if (eventEmitter) {
407
waitForTopologyConnected(topology, { readPreference: options.readPreference }, err => {
408
- if (err) return changeStream.emit('error', err);
+ if (err) {
409
+ changeStream.emit('error', err);
410
+ changeStream.emit('close');
411
+ return;
412
+ }
413
changeStream.cursor = createChangeStreamCursor(changeStream);
414
});
415
0 commit comments