fromWritableStream
Rx.Node.fromWritableStream(stream)
Rx.Node.fromWritableStream(stream)
Converts a flowing writeable stream to an Observable sequence.
Arguments
stream
(Stream): A stream to convert to a observable sequence.
Returns
(Observable): An observable sequence which fires on each 'data' event as well as handling 'error' and 'finish' events.
Example
Last updated