You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
25 lines
625 B
25 lines
625 B
7 years ago
|
const WritableStream = require('readable-stream').Writable
|
||
|
|
const promiseToCallback = require('promise-to-callback')
|
||
|
|
|
||
|
|
module.exports = createStreamSink
|
||
|
|
|
||
|
|
|
||
|
|
function createStreamSink(asyncWriteFn, _opts) {
|
||
|
|
return new AsyncWritableStream(asyncWriteFn, _opts)
|
||
|
|
}
|
||
|
|
|
||
|
|
class AsyncWritableStream extends WritableStream {
|
||
|
|
|
||
|
|
constructor (asyncWriteFn, _opts) {
|
||
|
|
const opts = Object.assign({ objectMode: true }, _opts)
|
||
|
|
super(opts)
|
||
|
|
this._asyncWriteFn = asyncWriteFn
|
||
|
|
}
|
||
|
|
|
||
|
|
// write from incomming stream to state
|
||
|
|
_write (chunk, encoding, callback) {
|
||
|
|
promiseToCallback(this._asyncWriteFn(chunk, encoding))(callback)
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|