fix(change_stream): emit 'close' event if reconnecting failed

mongodb · Jul 24, 2019 · f24c084 · f24c084
1 parent 15d69c8
commit f24c084
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/lib/change_stream.js b/lib/change_stream.js
@@ -405,7 +405,11 @@ function processNewChange(args) {
       // attempt recreating the cursor
       if (eventEmitter) {
         waitForTopologyConnected(topology, { readPreference: options.readPreference }, err => {
-          if (err) return changeStream.emit('error', err);
+          if (err) {
+            changeStream.emit('error', err);
+            changeStream.emit('close');
+            return;
+          }
           changeStream.cursor = createChangeStreamCursor(changeStream);
         });