aboutsummaryrefslogtreecommitdiffstats
path: root/app/scripts/lib/obj-multiplex.js
diff options
context:
space:
mode:
authorKevin Serrano <kevin.serrano@consensys.net>2017-09-19 02:46:10 +0800
committerKevin Serrano <kevin.serrano@consensys.net>2017-09-19 02:46:10 +0800
commit51f0911f8734745bed452e07f7bf1e5dc7211235 (patch)
tree6594bf81b2b42e8d2511435fd3058f1682177b10 /app/scripts/lib/obj-multiplex.js
parent456ceefcf7967423ea66e81d2108ffcb0e144082 (diff)
parentc463647ad7a825eb954a56599ec205a3ba6cd3e6 (diff)
downloadtangerine-wallet-browser-51f0911f8734745bed452e07f7bf1e5dc7211235.tar.gz
tangerine-wallet-browser-51f0911f8734745bed452e07f7bf1e5dc7211235.tar.zst
tangerine-wallet-browser-51f0911f8734745bed452e07f7bf1e5dc7211235.zip
Merge branch 'master' into new-currency-test
Diffstat (limited to 'app/scripts/lib/obj-multiplex.js')
-rw-r--r--app/scripts/lib/obj-multiplex.js48
1 files changed, 0 insertions, 48 deletions
diff --git a/app/scripts/lib/obj-multiplex.js b/app/scripts/lib/obj-multiplex.js
deleted file mode 100644
index 0034febe0..000000000
--- a/app/scripts/lib/obj-multiplex.js
+++ /dev/null
@@ -1,48 +0,0 @@
-const through = require('through2')
-
-module.exports = ObjectMultiplex
-
-function ObjectMultiplex (opts) {
- opts = opts || {}
- // create multiplexer
- const mx = through.obj(function (chunk, enc, cb) {
- const name = chunk.name
- const data = chunk.data
- if (!name) {
- console.warn(`ObjectMultiplex - Malformed chunk without name "${chunk}"`)
- return cb()
- }
- const substream = mx.streams[name]
- if (!substream) {
- console.warn(`ObjectMultiplex - orphaned data for stream "${name}"`)
- } else {
- if (substream.push) substream.push(data)
- }
- return cb()
- })
- mx.streams = {}
- // create substreams
- mx.createStream = function (name) {
- const substream = mx.streams[name] = through.obj(function (chunk, enc, cb) {
- mx.push({
- name: name,
- data: chunk,
- })
- return cb()
- })
- mx.on('end', function () {
- return substream.emit('end')
- })
- if (opts.error) {
- mx.on('error', function () {
- return substream.emit('error')
- })
- }
- return substream
- }
- // ignore streams (dont display orphaned data warning)
- mx.ignoreStream = function (name) {
- mx.streams[name] = true
- }
- return mx
-}