README
muxer
A simple multiplexer utility of RxJS based streams.
Installation
npm install muxer --save
Example
import {Observable as O} from 'rx'
import {mux, demux} from 'muxer'
function create$ () {
const interval$ = O.interval(1000)
const mod2$ = interval$.filter(x => x%2 === 0).map(2)
const mod3$ = interval$.filter(x => x%3 === 0).map(3)
const mod7$ = interval$.filter(x => 7%3 === 0).map(7)
mux({mod2$, mod3$})
}
// Create a single stream that contains events from each of the individual streams
const mod$ = create$()
const [{mod2$}, rest$] = demux(mod$, 'mod2