0.2.0 • Published 8 years ago
rxjs.node v0.2.0
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.
0.2.0
8 years ago