diff options
author | Kevin Serrano <kevin.serrano@consensys.net> | 2017-09-19 02:46:10 +0800 |
---|---|---|
committer | Kevin Serrano <kevin.serrano@consensys.net> | 2017-09-19 02:46:10 +0800 |
commit | 51f0911f8734745bed452e07f7bf1e5dc7211235 (patch) | |
tree | 6594bf81b2b42e8d2511435fd3058f1682177b10 /app/scripts/lib/obj-multiplex.js | |
parent | 456ceefcf7967423ea66e81d2108ffcb0e144082 (diff) | |
parent | c463647ad7a825eb954a56599ec205a3ba6cd3e6 (diff) | |
download | tangerine-wallet-browser-51f0911f8734745bed452e07f7bf1e5dc7211235.tar tangerine-wallet-browser-51f0911f8734745bed452e07f7bf1e5dc7211235.tar.gz tangerine-wallet-browser-51f0911f8734745bed452e07f7bf1e5dc7211235.tar.bz2 tangerine-wallet-browser-51f0911f8734745bed452e07f7bf1e5dc7211235.tar.lz tangerine-wallet-browser-51f0911f8734745bed452e07f7bf1e5dc7211235.tar.xz 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.js | 48 |
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 -} |