initial commit

node_modules/ternary-stream/index.js

@@ -0,0 +1,55 @@
+'use strict';
+
+var through2 = require('through2');
+var ForkStream = require('fork-stream');
+var mergeStream = require('merge-stream');
+var duplexify = require('duplexify');
+
+module.exports = function (condition, trueStream, falseStream) {
+	if (!trueStream) {
+		throw new Error('fork-stream: child action is required');
+	}
+
+	// output stream
+	var outStream = through2.obj();
+
+	// create fork-stream
+	var forkStream = new ForkStream({
+		classifier: function (e, cb) {
+			var ans = !!condition(e);
+			return cb(null, ans);
+		}
+	});
+
+	// if condition is true, pipe input to trueStream
+	forkStream.a.pipe(trueStream);
+
+	var mergedStream;
+
+	if (falseStream) {
+		// if there's an 'else' condition
+		// if condition is false
+		// pipe input to falseStream
+		forkStream.b.pipe(falseStream);
+		// merge output with trueStream's output
+		mergedStream = mergeStream(falseStream, trueStream);
+		// redirect falseStream errors to mergedStream
+		falseStream.on('error', function(err) { mergedStream.emit('error', err); });
+	} else {
+		// if there's no 'else' condition
+		// if condition is false
+		// merge output with trueStream's output
+		mergedStream = mergeStream(forkStream.b, trueStream);
+	}
+
+	// redirect trueStream errors to mergedStream
+	trueStream.on('error', function(err) { mergedStream.emit('error', err); });
+
+	// send everything down-stream
+	mergedStream.pipe(outStream);
+	// redirect mergedStream errors to outStream
+	mergedStream.on('error', function(err) { outStream.emit('error', err); });
+
+	// consumers write in to forkStream, we write out to outStream
+	return duplexify.obj(forkStream, outStream);
+};