Check for last error on foreach.

mongo-js · Mar 21, 2015 · a27cdcc · a27cdcc
1 parent 23c1a82
commit a27cdcc
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/lib/cursor.js b/lib/cursor.js
@@ -91,6 +91,8 @@ Cursor.prototype.forEach = function(fn) {
 
   var loop = function() {
     self.next(function(err, obj) {
+      if (err) return fn(err);
+      if (!obj) return;
       fn(err, obj);
       loop();
     });