Promising-Streams
Create Streams which utilise promises for their internal methods.
Usage
Readable([options,] read)
Readable can be called as a method or instantiated, either way it returns a new instance of a ReadablePromiseStream.
Examples
var readable = require('promising-streams').Readable
var arr = ['a', 'b', 'c', 'd', 'e'];
readable(() => Promise.resolve(arr.shift() || null))
.pipe(someOtherStream);This basically sets the streams internal _read method to call the
supplied read callback. The only difference to regular streams is
that the callback is set to __read rather than _read