pull-composed

Take many pull stream pipelines (source, though and sinks) and run them at once.

Takes each argument and executes them if they happen to be a function, the merged arguments are also returned.

install

npm install pull-composed

usage

var compose = require('pull-composed')

var x = function () {
        return pull(
                pull.values([ 0, 1, 2, 3 ]),
                pull.drain()
        )
}

var y = function () {
        return pull(
                pull.values([ 4, 5, 6, 7 ]),
                pull.drain()
        )
}

var z = compose(
        x,
        x,
        y,
        y,
        x,
        x,
        y
)

compose(x, z, x, y, z, compose(x), compose(x), z)

var x = compose(
        x, y,
        x, y
)

From a module

var pull = require('pull-stream');
var compose = require('pull-composed');

module.exports = function app () {
	var x = function () {
		return pull(
			pull.values([ 'demo' ]),
			pull.log()
		)
	}
	return compose(x);
};