Tooling to adapt node.js core functionality into RxJS

Takes in a node-stream and returns a Subject.

Convert an observable into a node-style callback.

Convert an observable into a promise. (Requires global Promise)

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