fromWritableStream

Rx.Node.fromWritableStream(stream)

# Ⓢ

Converts a flowing writeable stream to an Observable sequence.

Arguments

1. 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

var Rx = require('rx');

var subscription = Rx.Node.fromWritableStream(process.stdout)
    .subscribe(function (x) { console.log(x); });

// => r<Buffer 72>
// => x<Buffer 78>