rxjs.node

Tooling to adapt node.js core functionality into RxJS

API

fromStream(stream)

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