understream - npm Package Compare versions

Comparing version 0.10.7 to 0.10.8

lib-js/readables/combine.js

@@ -34,2 +34,7 @@ // Generated by CoffeeScript 1.6.3
     }
+    output = _.extend(output, {
+      _pipeline: function() {
+        return streams;
+      }
+    });
     return output;
@@ -36,0 +41,0 @@ }

lib-js/transforms/join.js

@@ -248,8 +248,8 @@ // Generated by CoffeeScript 1.6.3
     }) : new HashJoin(this.stream_opts, this.options);
-    return _.extend(join_instance, {
+    join_instance = _.extend(join_instance, {
       _pipeline: function() {
-        var _base;
-        return [join_instance].concat((typeof (_base = _this.options.from)._pipeline === "function" ? _base._pipeline() : void 0) || [_this.options.from]);
+        return [_this.options.from];
       }
     });
+    return join_instance;
   }
@@ -256,0 +256,0 @@

lib-js/understream.js

@@ -81,3 +81,7 @@ // Generated by CoffeeScript 1.6.3
   return _.flatten(_(streams).map(function(stream) {
-    return (typeof stream._pipeline === "function" ? stream._pipeline() : void 0) || [stream];
+    if (stream._pipeline != null) {
+      return pipeline_of_streams(_.without(stream._pipeline(), stream)).concat([stream]);
+    } else {
+      return [stream];
+    }
   }));
@@ -116,2 +120,5 @@ };
     });
+    this._pipeline = function() {
+      return streams;
+    };
   }
@@ -237,3 +244,3 @@
       _pipeline: function() {
-        return pipeline_of_streams(streams).concat([last]);
+        return streams;
       }
@@ -244,12 +251,7 @@ });
   Understream.prototype.duplex = function() {
-    var _this = this;
-    return _.extend((function(func, args, ctor) {
+    return (function(func, args, ctor) {
       ctor.prototype = func.prototype;
       var child = new ctor, result = func.apply(child, args);
       return Object(result) === result ? result : child;
-    })(StreamCombiner, this._streams, function(){}), {
-      _pipeline: function() {
-        return pipeline_of_streams(_this._streams);
-      }
-    });
+    })(StreamCombiner, this._streams, function(){});
   };
@@ -256,0 +258,0 @@

package.json

 {
   "name": "understream",
-  "version": "0.10.7",
+  "version": "0.10.8",
   "description": "stream helpers",
@@ -5,0 +5,0 @@ "engines": {

No alert changes

Improved metrics

Total package byte prevSize

133980

1.32%

Lines of code

1274

0.55%

No dependency changes