stream-to-promise

Convert streams (readable or writable) to promises

Installing

1npm install --save stream-to-promise

Examples

Readable Streams

1streamToPromise(readableStream).then(function (buffer) {
2  // buffer.length === 3
3})
4readableStream.emit('data', new Buffer())
5readableStream.emit('data', new Buffer())
6readableStream.emit('data', new Buffer())
7readableStream.emit('end') // promise is resolved here

Writable Streams

1streamToPromise(writableStream).then(function () {
2  // resolves undefined
3})
4writableStream.write('data')
5writableStream.end() // promise is resolved here

Error Handling

1const err = new Error()
2streamToPromise(stream).catch(function (error) {
3  // error === err
4})
5stream.emit('error', err) // promise is rejected here