feat: Ensure readable does not end until read from

index.js

@@ -43,10 +43,6 @@ function OrderedStreams(streams, options) {
   var streamIdx = 0;
   var activeStream = streams[streamIdx];
 
-  if (!activeStream) {
-    readable.push(null);
-  }
-
   var destroyedIdx = -1;
   var destroyedByError = false;
   var readableClosed = false;
@@ -122,7 +118,11 @@ function OrderedStreams(streams, options) {
   }
 
   function read(cb) {
-    activeStream.resume();
+    if (activeStream) {
+      activeStream.resume();
+    } else {
+      readable.push(null);
+    }
     cb();
   }
 

test/main.js

@@ -66,6 +66,24 @@ function suite(moduleName) {
       stream.pipeline([streams, concat()], done);
     });
 
+    it('does not end until it is read if no streams are given', function (done) {
+      var streams = new OrderedStreams();
+
+      var ended = false;
+
+      streams.on('end', function () {
+        ended = true;
+      });
+      setTimeout(function () {
+        expect(ended).toEqual(false);
+
+        stream.pipeline([streams, concat()], function (err) {
+          expect(ended).toEqual(true);
+          done(err);
+        });
+      }, 250);
+    });
+
     it('throws an error if stream is not readable', function (done) {
       var writable = new stream.Writable({ write: function () {} });