ternary-stream - npm Package Compare versions

Comparing version 1.0.1 to 1.1.0

index.js

 'use strict';
 
-var duplexer = require('duplexer');
 var through2 = require('through2');
 var ForkStream = require('fork-stream');
+var eventStream = require('event-stream');
+var duplexer2 = require('duplexer2');
 
@@ -25,18 +26,24 @@ module.exports = function (condition, trueStream, falseStream) {
 	forkStream.a.pipe(trueStream);
-	// then send down-stream
-	trueStream.pipe(outStream);
 
+	var mergedStream;
+
 	if (falseStream) {
 		// if there's an 'else' condition
-		// if condition is false, pipe input to falseStream 
+		// if condition is false
+		// pipe input to falseStream 
 		forkStream.b.pipe(falseStream);
-		// then send down-stream
-		falseStream.pipe(outStream);
+		// merge output with trueStream's output
+		mergedStream = eventStream.merge(falseStream, trueStream);
 	} else {
 		// if there's no 'else' condition
-		// if condition is false, pipe down-stream 
-		forkStream.b.pipe(outStream);
+		// if condition is false
+		// merge output with trueStream's output
+		mergedStream = eventStream.merge(forkStream.b, trueStream);
 	}
 
-	return duplexer(forkStream, outStream);
+	// send everything down-stream
+	mergedStream.pipe(outStream);
+
+	// consumers write in to forkStream, we write out to outStream
+	return duplexer2(forkStream, outStream);
 };

package.json

 {
   "name": "ternary-stream",
   "description": "Fork stream based on passed condition, and collect down-stream",
-  "version": "1.0.1",
+  "version": "1.1.0",
   "homepage": "https://github.com/robrich/ternary-stream",
@@ -16,3 +16,4 @@ "repository": "git://github.com/robrich/ternary-stream.git",
   "dependencies": {
-    "duplexer": "^0.1.1",
+    "duplexer2": "^0.0.2",
+    "event-stream": "^3.1.2",
     "fork-stream": "^0.0.4",
@@ -19,0 +20,0 @@ "through2": "^0.4.1"

No alert changes

Improved metrics

Total package byte prevSize

27997

1.01%

Lines of code

39

14.71%

Worsened metrics

Dependency count

4

33.33%

Dependency changes

• + Added

  duplexer2@^0.0.2

• + Added

  event-stream@^3.1.2

• + Added

  duplexer2@0.0.2
  (transitive)

• + Added

  event-stream@3.3.5
  (transitive)

• + Added

  from@0.1.7
  (transitive)

• + Added

  map-stream@0.0.7
  (transitive)

• + Added

  pause-stream@0.0.11
  (transitive)

• + Added

  readable-stream@1.1.14
  (transitive)

• + Added

  split@1.0.1
  (transitive)

• + Added

  stream-combiner@0.2.2
  (transitive)

• + Added

  through@2.3.8
  (transitive)

• - Removed

  duplexer@^0.1.1