fix(changestream): removes all event listeners on close

Fixes Node-1727
mongodb · Aug 13, 2019 · 30eeeb5 · 30eeeb5
1 parent dc1387e
commit 30eeeb5
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/lib/change_stream.js b/lib/change_stream.js
@@ -154,6 +154,7 @@ class ChangeStream extends EventEmitter {
 
     // Tidy up the existing cursor
     var cursor = this.cursor;
+    ['data', 'close', 'end', 'error'].forEach(event => this.cursor.removeAllListeners(event));
     delete this.cursor;
     return cursor.close(callback);
   }