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.
19 lines
584 B
19 lines
584 B
import { Writable as WritableStream } from 'readable-stream'
|
|
import promiseToCallback from 'promise-to-callback'
|
|
|
|
class AsyncWritableStream extends WritableStream {
|
|
constructor(asyncWriteFn, _opts) {
|
|
const opts = { objectMode: true, ..._opts }
|
|
super(opts)
|
|
this._asyncWriteFn = asyncWriteFn
|
|
}
|
|
|
|
// write from incoming stream to state
|
|
_write(chunk, encoding, callback) {
|
|
promiseToCallback(this._asyncWriteFn(chunk, encoding))(callback)
|
|
}
|
|
}
|
|
|
|
export default function createStreamSink(asyncWriteFn, _opts) {
|
|
return new AsyncWritableStream(asyncWriteFn, _opts)
|
|
}
|
|
|