# fromStream

## `Rx.Node.fromStream(stream)` <a href="#rxnodefromstreamstream" id="rxnodefromstreamstream"></a>

[#](#rxnodefromstreamstream) [Ⓢ](https://github.com/Reactive-Extensions/RxJS/blob/master/rx.node.js#L91-L115)

Converts a flowing 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 'end' events.

### Example

```javascript
var Rx = require('rx');

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

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