> For the complete documentation index, see [llms.txt](https://soufatn.gitbook.io/rxjs-book/llms.txt). Markdown versions of documentation pages are available by appending `.md` to page URLs; this page is available as [Markdown](https://soufatn.gitbook.io/rxjs-book/summary/rxjs_bindings/node/stream_handlers/from_writable_stream.md).

# fromWritableStream

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

[#](/rxjs-book/summary/rxjs_bindings/node/stream_handlers/from_writable_stream.md#rxnodefromwritablestreamstream) [Ⓢ](https://github.com/Reactive-Extensions/RxJS/blob/master/rx.node.js#L132-L134)

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

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

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

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