fix data being emitted out of order on a large peeked stream

Author: seangarner

CHANGELOG.md

@@ -1,5 +1,9 @@
 # buffer-peek-stream changelog
 
+## 0.1.2 (2014/11/07)
+
+  - fix data being emitted out of order on a large peeked stream
+
 ## 0.1.1 (2014/11/05)
 
   - fix typo in require

lib/buffer-peek-stream.js

@@ -56,6 +56,8 @@ BufferPeekStream.prototype.__stopPeeking = function __stopPeeking() {
   // unpipe from upstream
   this.__src.unpipe(this);
 
+  //TODO: find out if this stream can still get data after unpiping under any circumstance 
+
   var buffer = Buffer.concat(this.__buffer);
   var source = this.__src;
 
@@ -78,16 +80,10 @@ BufferPeekStream.prototype.__stopPeeking = function __stopPeeking() {
     source._readableState.emittedReadable = true;
     source._readableState.readableListening = false;
     source._readableState.readingMore = false;
-
-    source.unshift(buffer);
-  } else {
-    // delay unshifting all chunks back onto parent until we're drained so we don't lose chunks that
-    // have already been put onto the event stack before we unpiped.
-    this.once('drain', function () {
-      source.unshift(buffer);
-    });
   }
 
+  source.unshift(buffer);
+
   // we don't need to keep the original buffers
   this.__buffer = null;
 };

package.json

@@ -1,6 +1,6 @@
 {
   "name": "buffer-peek-stream",
-  "version": "0.1.1",
+  "version": "0.1.2",
   "description": "Transform stream that lets you inspect the start of a ReadStream before deciding what to do with it",
   "main": "lib/index.js",
   "scripts": {