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

mongodb · Aug 13, 2019 · 41aba90 · 41aba90
1 parent f38e261
commit 41aba90
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/lib/change_stream.js b/lib/change_stream.js
@@ -399,7 +399,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);
         });