pausable

dominictarr · Feb 5, 2013 · bc2447e · bc2447e
1 parent a1e520d
commit bc2447e
Showing 1 changed file with 4 additions and 6 deletions.
diff --git a/index.js b/index.js
@@ -29,18 +29,16 @@ function split (matcher, mapper) {
       if(mapper) {
         piece = mapper(piece)
         if('undefined' !== typeof piece)
-          stream.emit('data', piece)
+          stream.queue(piece)
       }
       else
-        stream.emit('data', piece)
+        stream.queue(piece)
     }
-
-    return true
   },
   function () {
     if(soFar)
-      this.emit('data', soFar)  
-    this.emit('end')
+      this.queue(soFar)  
+    this.queue(null)
   })
 }