writeToStream

Rx.Node.writeToStream(observable, stream, [encoding])

# Ⓢ

Writes an observable sequence to a stream.

Arguments

1. observable (Obsesrvable): Observable sequence to write to a stream.

2. stream (Stream): The stream to write to.

3. [encoding] (String): The encoding of the item to write.

Returns

(Disposable): The subscription handle.

Example

var Rx = require('Rx');

var source = Rx.Observable.range(0, 5);

var subscription = Rx.Node.writeToStream(source, process.stdout, 'utf8');

// => 01234