aboutsummaryrefslogtreecommitdiffstats
path: root/app/scripts/lib/stream-utils.js
diff options
context:
space:
mode:
authorkumavis <kumavis@users.noreply.github.com>2016-04-16 04:06:28 +0800
committerkumavis <kumavis@users.noreply.github.com>2016-04-16 04:06:28 +0800
commit83b8741bbb335ad1629b72180616835dbb3f5433 (patch)
treeb8adfc80551c1032dc6fc43aa3a5055169446143 /app/scripts/lib/stream-utils.js
parent81fc1e5f7dc958af40d8113b80c8cfb38c2016ef (diff)
parentd6114292d0c05b42b1d28d75baad8af0c06509a1 (diff)
downloadtangerine-wallet-browser-83b8741bbb335ad1629b72180616835dbb3f5433.tar
tangerine-wallet-browser-83b8741bbb335ad1629b72180616835dbb3f5433.tar.gz
tangerine-wallet-browser-83b8741bbb335ad1629b72180616835dbb3f5433.tar.bz2
tangerine-wallet-browser-83b8741bbb335ad1629b72180616835dbb3f5433.tar.lz
tangerine-wallet-browser-83b8741bbb335ad1629b72180616835dbb3f5433.tar.xz
tangerine-wallet-browser-83b8741bbb335ad1629b72180616835dbb3f5433.tar.zst
tangerine-wallet-browser-83b8741bbb335ad1629b72180616835dbb3f5433.zip
Merge pull request #113 from MetaMask/i53
publicConfigStore for sync provider and selected address
Diffstat (limited to 'app/scripts/lib/stream-utils.js')
-rw-r--r--app/scripts/lib/stream-utils.js16
1 files changed, 16 insertions, 0 deletions
diff --git a/app/scripts/lib/stream-utils.js b/app/scripts/lib/stream-utils.js
index 12560ffd8..fd4417d94 100644
--- a/app/scripts/lib/stream-utils.js
+++ b/app/scripts/lib/stream-utils.js
@@ -1,9 +1,11 @@
const Through = require('through2')
+const ObjectMultiplex = require('./obj-multiplex')
module.exports = {
jsonParseStream: jsonParseStream,
jsonStringifyStream: jsonStringifyStream,
+ setupMultiplex: setupMultiplex,
}
function jsonParseStream(){
@@ -19,3 +21,17 @@ function jsonStringifyStream(){
cb()
})
}
+
+function setupMultiplex(connectionStream){
+ var mx = ObjectMultiplex()
+ connectionStream.pipe(mx).pipe(connectionStream)
+ mx.on('error', function(err) {
+ console.error(err)
+ // connectionStream.destroy()
+ })
+ connectionStream.on('error', function(err) {
+ console.error(err)
+ mx.destroy()
+ })
+ return mx
+} \ No newline at end of file