SequenceStream now only starts piping once it has been hooked up to a…

… pipe itself

SequenceStream.js

@@ -34,7 +34,7 @@ class SequenceStream extends stream.Transform {
         this._enabled = false;
         return this.end();
       }
-      this._current = this._streams.shift();
+      this._current = new stream.Readable().wrap(this._streams.shift());
       this._current.on('end', () => {
         this._current = null;
         this._next();
@@ -58,9 +58,18 @@ class SequenceStream extends stream.Transform {
         this._streams = this._streams.concat(stream);
       }
     }
-    this._next();
     return this;
   }
+
+  /**
+   * Overrides the pipe function so that we don't wire up any chains before there's a pipe to send data to.
+   * @returns {Stream}
+   */
+  pipe() {
+    var stream = super.pipe.apply(this, arguments);
+    this._next();
+    return stream;
+  }
 }
 
 module.exports = SequenceStream;

package.json

@@ -1,6 +1,6 @@
 {
   "name": "more-streams",
-  "version": "0.5.6",
+  "version": "0.5.7",
   "description": "A collection of useful stream implementations",
   "license": "Apache-2.0",
   "homepage": "http://github.com/mallocator/more-streams",