Breaking: Use cloneable-readable to clone streams - possibly breaking (closes #85)

Author: phated

index.js

@@ -8,8 +8,8 @@ var isStream = require('./lib/isStream');
 var isNull = require('./lib/isNull');
 var inspectStream = require('./lib/inspectStream');
 var normalize = require('./lib/normalize');
-var Stream = require('readable-stream');
 var replaceExt = require('replace-ext');
+var cloneable = require('cloneable-readable');
 
 var builtInFields = [
   '_contents', '_symlink', 'contents', 'stat', 'history', 'path',
@@ -111,8 +111,11 @@ File.prototype.clone = function(opt) {
   // Clone our file contents
   var contents;
   if (this.isStream()) {
-    contents = this.contents.pipe(new Stream.PassThrough());
-    this.contents = this.contents.pipe(new Stream.PassThrough());
+    if (typeof this.contents.clone !== 'function') {
+      this.contents = cloneable(this.contents);
+    }
+
+    contents = this.contents.clone();
   } else if (this.isBuffer()) {
     contents = opt.contents ? cloneBuffer(this.contents) : this.contents;
   }
@@ -173,6 +176,11 @@ Object.defineProperty(File.prototype, 'contents', {
     if (!isBuffer(val) && !isStream(val) && !isNull(val)) {
       throw new Error('File.contents can only be a Buffer, a Stream, or null.');
     }
+
+    if (isStream(val)) {
+      val = cloneable(val);
+    }
+
     this._contents = val;
   },
 });

package.json

@@ -13,6 +13,7 @@
   "dependencies": {
     "clone": "^1.0.0",
     "clone-stats": "^1.0.0",
+    "cloneable-readable": "^0.1.0",
     "readable-stream": "^2.1.0",
     "replace-ext": "^1.0.0"
   },

test/File.js

@@ -636,7 +636,7 @@ describe('File', function() {
         path: '/test/test.coffee',
         contents: new Stream.PassThrough(),
       });
-      file.inspect().should.equal('<File "test.coffee" <PassThroughStream>>');
+      file.inspect().should.equal('<File "test.coffee" <CloneableStream>>');
       done();
     });
 
@@ -661,11 +661,11 @@ describe('File', function() {
       done();
     });
 
-    it('should work with Stream', function(done) {
-      var val = new Stream.PassThrough();
+    it('should wrap Stream in Cloneable', function(done) {
+      var val = new Stream();
       var file = new File();
       file.contents = val;
-      file.contents.should.equal(val);
+      (typeof file.contents.clone).should.equal('function');
       done();
     });