feat!: Remove cloneable-readable (#155)

feat!: Clone streams with teex
feat!: No longer await all streams to flow before emitting data

index.js

@@ -5,7 +5,7 @@ var util = require('util');
 var Buffer = require('buffer').Buffer;
 
 var clone = require('clone');
-var cloneable = require('cloneable-readable');
+var teex = require('teex');
 var replaceExt = require('replace-ext');
 var cloneStats = require('clone-stats');
 var removeTrailingSep = require('remove-trailing-separator');
@@ -122,7 +122,9 @@ File.prototype.clone = function (opt) {
   // Clone our file contents
   var contents;
   if (this.isStream()) {
-    contents = this.contents.clone();
+    var streams = teex(this._contents);
+    this._contents = streams[0];
+    contents = streams[1];
   } else if (this.isBuffer()) {
     contents = opt.contents ? Buffer.from(this.contents) : this.contents;
   }
@@ -189,13 +191,6 @@ Object.defineProperty(File.prototype, 'contents', {
       throw new Error('File.contents can only be a Buffer, a Stream, or null.');
     }
 
-    // Ask cloneable if the stream is a already a cloneable
-    // this avoid piping into many streams
-    // reducing the overhead of cloning
-    if (isStream(val) && !cloneable.isCloneable(val)) {
-      val = cloneable(val);
-    }
-
     this._contents = val;
   },
 });

package.json

@@ -24,20 +24,21 @@
     "test": "nyc mocha --async-only"
   },
   "dependencies": {
-    "clone": "^2.1.1",
+    "clone": "^2.1.2",
     "clone-stats": "^1.0.0",
-    "cloneable-readable": "^2.1.0",
-    "remove-trailing-separator": "^1.0.1",
-    "replace-ext": "^2.0.0"
+    "remove-trailing-separator": "^1.1.0",
+    "replace-ext": "^2.0.0",
+    "teex": "^1.0.1"
   },
   "devDependencies": {
     "eslint": "^7.32.0",
     "eslint-config-gulp": "^5.0.1",
     "eslint-plugin-node": "^11.1.0",
     "expect": "^27.4.6",
-    "mississippi": "^4.0.0",
     "mocha": "^8.4.0",
-    "nyc": "^15.1.0"
+    "nyc": "^15.1.0",
+    "readable-stream": "^3.6.0",
+    "streamx": "^2.12.5"
   },
   "nyc": {
     "reporter": [