diff options
author | kumavis <aaron@kumavis.me> | 2018-06-14 07:45:18 +0800 |
---|---|---|
committer | kumavis <aaron@kumavis.me> | 2018-06-14 07:45:18 +0800 |
commit | 7b414f3ed08b8eb35ce7a8e076e4ffd75fea3d30 (patch) | |
tree | 3d037349648c3b785aa08ffe45535e0e8aa5349c /app/scripts/lib/createStreamSink.js | |
parent | 451d05a400302d443e13d4d75a7094bf20e86d97 (diff) | |
download | tangerine-wallet-browser-7b414f3ed08b8eb35ce7a8e076e4ffd75fea3d30.tar.gz tangerine-wallet-browser-7b414f3ed08b8eb35ce7a8e076e4ffd75fea3d30.tar.zst tangerine-wallet-browser-7b414f3ed08b8eb35ce7a8e076e4ffd75fea3d30.zip |
background - persistence pipeline - fix persistence bug
Diffstat (limited to 'app/scripts/lib/createStreamSink.js')
-rw-r--r-- | app/scripts/lib/createStreamSink.js | 24 |
1 files changed, 24 insertions, 0 deletions
diff --git a/app/scripts/lib/createStreamSink.js b/app/scripts/lib/createStreamSink.js new file mode 100644 index 000000000..cf9416fea --- /dev/null +++ b/app/scripts/lib/createStreamSink.js @@ -0,0 +1,24 @@ +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) + } + +} |