fromTransformStream

Rx.Node.fromTransformStream(stream)

# Ⓢ

Converts a flowing transform stream to an Observable sequence.

参数

1. stream (Stream): A stream to convert to a observable sequence.

返回值

(Observable): An observable sequence which fires on each 'data' event as well as handling 'error' and 'finish' events.

例

var Rx = require('rx');

var subscription = Rx.Node.fromTransformStream(getTransformStreamSomehow());