diff options
author | Kevin Serrano <kevgagser@gmail.com> | 2017-08-03 07:20:53 +0800 |
---|---|---|
committer | GitHub <noreply@github.com> | 2017-08-03 07:20:53 +0800 |
commit | 2c37d438885865fb9b93769a6dee9fb32f8d82aa (patch) | |
tree | 19ed66e8fd54b4324d8e5750de061c6562ace19b /app/scripts/lib/obj-multiplex.js | |
parent | d15e402ed87bf7533250c49a7972a7b1a12c99c2 (diff) | |
parent | 8c6f01b91094564df59d6d95b6f43b811e711824 (diff) | |
download | tangerine-wallet-browser-2c37d438885865fb9b93769a6dee9fb32f8d82aa.tar.gz tangerine-wallet-browser-2c37d438885865fb9b93769a6dee9fb32f8d82aa.tar.zst tangerine-wallet-browser-2c37d438885865fb9b93769a6dee9fb32f8d82aa.zip |
Merge pull request #1849 from MetaMask/blacklist-refactor
Blacklist refactor
Diffstat (limited to 'app/scripts/lib/obj-multiplex.js')
-rw-r--r-- | app/scripts/lib/obj-multiplex.js | 16 |
1 files changed, 10 insertions, 6 deletions
diff --git a/app/scripts/lib/obj-multiplex.js b/app/scripts/lib/obj-multiplex.js index bd114c394..0034febe0 100644 --- a/app/scripts/lib/obj-multiplex.js +++ b/app/scripts/lib/obj-multiplex.js @@ -5,12 +5,16 @@ module.exports = ObjectMultiplex function ObjectMultiplex (opts) { opts = opts || {} // create multiplexer - var mx = through.obj(function (chunk, enc, cb) { - var name = chunk.name - var data = chunk.data - var substream = mx.streams[name] + 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(`orphaned data for stream "${name}"`) + console.warn(`ObjectMultiplex - orphaned data for stream "${name}"`) } else { if (substream.push) substream.push(data) } @@ -19,7 +23,7 @@ function ObjectMultiplex (opts) { mx.streams = {} // create substreams mx.createStream = function (name) { - var substream = mx.streams[name] = through.obj(function (chunk, enc, cb) { + const substream = mx.streams[name] = through.obj(function (chunk, enc, cb) { mx.push({ name: name, data: chunk, |