rxjs.node
v0.2.0
Published
[](http://ipn.io) [](http://ipfs.io/) [
Takes in a node-stream and returns a Subject.
toCallback(observable, cb)
Convert an observable into a node-style callback.
toPromise(observable)
Convert an observable into a promise. (Requires global Promise)
SocketSubject(options)
StreamSubject(options)
Acknowledgements
Thank you to all the contributors on these projects for going before me.
- https://github.com/Reactive-Extensions/rx-node
- https://github.com/HackerHappyHour/rxjs-node
- https://github.com/Reactive-Extensions/RxJS
