pull mux
Combine and namepsace multiple streams.
install
$ npm install pull-mux
example
var test = require('tape')var S = require('pull-stream')var mux = require('../') test('create a namespaced stream from an object', function (t) { t.plan(2) var streams = { a: S.values([1,2,3]), b: S.values([4,5,6]) } var stream = mux(streams) S( stream, S.collect(function (err, res) { t.error(err) t.deepEqual(res, [ ['a', 1], ['b', 4], ['a', 2], ['b', 5], ['a', 3], ['b', 6] ], 'should namespace the events') }) )}) test('pass in a mux function', function (t) { t.plan(2) var streams = { a: S.values([1,2]), b: S.values([3,4]) } var stream = mux(streams, function muxer (type, ev) { return { type: type, data: ev } }) S( stream, S.collect(function (err, res) { t.error(err) t.deepEqual(res, [ { type: 'a', data: 1 }, { type: 'b', data: 3 }, { type: 'a', data: 2 }, { type: 'b', data: 4 }, ], 'should map the events') }) )})