fix(cursor): close readable on null response for dead cursor

mongodb · Aug 30, 2017 · 6aca2c5 · 6aca2c5
1 parent 6bb7e33
commit 6aca2c5
Show file tree

Hide file tree

Showing 2 changed files with 119 additions and 162 deletions.
diff --git a/lib/cursor.js b/lib/cursor.js
@@ -1081,6 +1081,13 @@ Cursor.prototype._read = function() {
       return self.emit('finish');
     }
 
+    if (result === null && self.isDead()) {
+      self.close();
+      self.emit('end');
+      self.emit('finish');
+      return;
+    }
+
     // If we provided a transformation method
     if(typeof self.s.streamOptions.transform == 'function' && result != null) {
       return self.push(self.s.streamOptions.transform(result));