diff options
| author | frankiebee <frankie.diamond@gmail.com> | 2017-09-27 07:24:43 +0800 |
|---|---|---|
| committer | frankiebee <frankie.diamond@gmail.com> | 2017-09-27 07:24:43 +0800 |
| commit | 8ab23c713db1f5d45abb0ba433450591b8759809 (patch) | |
| tree | c192fcf5eec3c7b422f3d0a91a4a96037c7f2fa6 /app/scripts/lib/stream-utils.js | |
| parent | 77a48fb0b16d7415377b02a3b7d383c9ef86fcb6 (diff) | |
| parent | 6ca519e97c4c282023ab6b7788715ff8d7ec8189 (diff) | |
| download | tangerine-wallet-browser-8ab23c713db1f5d45abb0ba433450591b8759809.tar.gz tangerine-wallet-browser-8ab23c713db1f5d45abb0ba433450591b8759809.tar.zst tangerine-wallet-browser-8ab23c713db1f5d45abb0ba433450591b8759809.zip | |
Merge branch 'master' into transactionControllerRefractorPt3
Diffstat (limited to 'app/scripts/lib/stream-utils.js')
| -rw-r--r-- | app/scripts/lib/stream-utils.js | 24 |
1 files changed, 12 insertions, 12 deletions
diff --git a/app/scripts/lib/stream-utils.js b/app/scripts/lib/stream-utils.js index ba79990cc..8bb0b4f3c 100644 --- a/app/scripts/lib/stream-utils.js +++ b/app/scripts/lib/stream-utils.js @@ -1,6 +1,6 @@ const Through = require('through2') -const endOfStream = require('end-of-stream') -const ObjectMultiplex = require('./obj-multiplex') +const ObjectMultiplex = require('obj-multiplex') +const pump = require('pump') module.exports = { jsonParseStream: jsonParseStream, @@ -23,14 +23,14 @@ function jsonStringifyStream () { } function setupMultiplex (connectionStream) { - var mx = ObjectMultiplex() - connectionStream.pipe(mx).pipe(connectionStream) - endOfStream(mx, function (err) { - if (err) console.error(err) - }) - endOfStream(connectionStream, function (err) { - if (err) console.error(err) - mx.destroy() - }) - return mx + const mux = new ObjectMultiplex() + pump( + connectionStream, + mux, + connectionStream, + (err) => { + if (err) console.error(err) + } + ) + return mux } |