dynamic-duplex

Dynamically wires up a duplex stream based on the data it receives.

Installation

This module is installed via npm:

$ npm install dynamic-duplex

Testing

This module can be tested by running:

$ npm run test

Example Usage

var Readable = require('stream').Readable;
var streamify = require('stream-array');
var dynamicDuplex = require('dynamic-duplex');

var input = new Readable({objectMode: true});

var streams = {
	a: streamify([1,2,3,4]),
	b: streamify([5,6,7,8])
};
input.pipe(dynamicDuplex(function(letter, en, cb) {
	cb(null, streams[letter]);
})).pipe(through(function(chunk, end, cb) {
	console.log(chunk);

	if (chunk === 2) {
		// force a switch to stream b
		input.push('b');
	}

	cb();
}));

// To get the ball rolling
input.push('a');

// Expected output from this code is:
// 1 2 5 6 7 8