better errors

Author: dominictarr

index.js

@@ -3,46 +3,27 @@ var noop = function () {}
 module.exports = function (next) {
   var stream
   return function (abort, cb) {
+    if(!cb) throw new Error('callback required!')
     if(abort) {
       if(stream) stream(abort, cb)
       else       cb(abort)
     }
-    else
-      more()
-
-    function more () {
+    else (function more () {
       if(!stream) {
         try { stream = next() }
         catch(err) { return cb(err) }
         if(!stream) return cb(true)
       }
       stream(null, function (err, data) {
         if(err) {
-          console.log('end', err, data)
           stream = null
           if(err === true) setTimeout(more, 100)
           else             cb(err)
         }
         else
           cb(null, data)
       })
-    }
+    })()
   }
 }
 
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-