Fix sink from preventing the readable event to fire on the underlying stream

Author: benurb

lib/sink.js

@@ -11,6 +11,11 @@ function sink(stream) {
   });
 
   return function() {
+    // Respect readable listeners on the underlying stream
+    if (stream.listeners('readable').length > 0) {
+      return;
+    }
+
     stream.pipe(sinkStream);
   };
 }

test/dest.js

@@ -1337,6 +1337,29 @@ describe('dest stream', function() {
       .pipe(slowCountFiles);
   });
 
+  it('should respect readable listeners on destination stream', function(done) {
+    var srcPath = path.join(__dirname, './fixtures/test.coffee');
+    var srcStream = vfs.src(srcPath);
+    var destStream = vfs.dest('./out-fixtures/', { cwd: __dirname });
+
+    srcStream
+      .pipe(destStream);
+
+    var readables = 0;
+    destStream.on('readable', function() {
+      var data = destStream.read();
+
+      if (data == null) {
+        // Stream ended
+        readables.should.equal(1);
+        done();
+      } else {
+        // New data
+        readables++;
+      }
+    });
+  });
+
   it('should pass options to through2', function(done) {
     var srcPath = path.join(__dirname, './fixtures/test.coffee');
     var content = fs.readFileSync(srcPath);