diff options
author | Dan Finlay <dan@danfinlay.com> | 2017-09-23 05:12:41 +0800 |
---|---|---|
committer | Dan Finlay <dan@danfinlay.com> | 2017-09-23 05:12:41 +0800 |
commit | f9d2f523c628228a77c28e7d46d08151453a47bc (patch) | |
tree | a6fbca183622486f2107a885d5e6d3158f20a35a /app/scripts/lib/port-stream.js | |
parent | d2a747e57e591af5beb2e7cef7fc73a363d9c742 (diff) | |
parent | 73d9434ad63e18a87bd3ed13a285eb37c9c6ae7c (diff) | |
download | tangerine-wallet-browser-f9d2f523c628228a77c28e7d46d08151453a47bc.tar.gz tangerine-wallet-browser-f9d2f523c628228a77c28e7d46d08151453a47bc.tar.zst tangerine-wallet-browser-f9d2f523c628228a77c28e7d46d08151453a47bc.zip |
Merge branch 'master' into AddBalanceController
Diffstat (limited to 'app/scripts/lib/port-stream.js')
-rw-r--r-- | app/scripts/lib/port-stream.js | 16 |
1 files changed, 2 insertions, 14 deletions
diff --git a/app/scripts/lib/port-stream.js b/app/scripts/lib/port-stream.js index 607a9c9ed..648d88087 100644 --- a/app/scripts/lib/port-stream.js +++ b/app/scripts/lib/port-stream.js @@ -1,5 +1,6 @@ const Duplex = require('readable-stream').Duplex const inherits = require('util').inherits +const noop = function(){} module.exports = PortDuplexStream @@ -20,20 +21,14 @@ PortDuplexStream.prototype._onMessage = function (msg) { if (Buffer.isBuffer(msg)) { delete msg._isBuffer var data = new Buffer(msg) - // console.log('PortDuplexStream - saw message as buffer', data) this.push(data) } else { - // console.log('PortDuplexStream - saw message', msg) this.push(msg) } } PortDuplexStream.prototype._onDisconnect = function () { - try { - this.push(null) - } catch (err) { - this.emit('error', err) - } + this.destroy() } // stream plumbing @@ -45,19 +40,12 @@ PortDuplexStream.prototype._write = function (msg, encoding, cb) { if (Buffer.isBuffer(msg)) { var data = msg.toJSON() data._isBuffer = true - // console.log('PortDuplexStream - sent message as buffer', data) this._port.postMessage(data) } else { - // console.log('PortDuplexStream - sent message', msg) this._port.postMessage(msg) } } catch (err) { - // console.error(err) return cb(new Error('PortDuplexStream - disconnected')) } cb() } - -// util - -function noop () {} |