diff options
author | kumavis <kumavis@users.noreply.github.com> | 2016-06-22 05:24:28 +0800 |
---|---|---|
committer | GitHub <noreply@github.com> | 2016-06-22 05:24:28 +0800 |
commit | 537328b5298a42f9d20862d42b9012babcda373c (patch) | |
tree | 9a5728447f5b23a918b4a23c12e91ea1b702e527 /app/scripts/lib/stream-utils.js | |
parent | bb7788373d9c234313d651d88c72c18a8e4ca0aa (diff) | |
parent | d7c3e8e9f5182576eb4a990d385ff8ce4ebd417c (diff) | |
download | tangerine-wallet-browser-537328b5298a42f9d20862d42b9012babcda373c.tar tangerine-wallet-browser-537328b5298a42f9d20862d42b9012babcda373c.tar.gz tangerine-wallet-browser-537328b5298a42f9d20862d42b9012babcda373c.tar.bz2 tangerine-wallet-browser-537328b5298a42f9d20862d42b9012babcda373c.tar.lz tangerine-wallet-browser-537328b5298a42f9d20862d42b9012babcda373c.tar.xz tangerine-wallet-browser-537328b5298a42f9d20862d42b9012babcda373c.tar.zst tangerine-wallet-browser-537328b5298a42f9d20862d42b9012babcda373c.zip |
Merge pull request #303 from MetaMask/AutoLint
Auto lint
Diffstat (limited to 'app/scripts/lib/stream-utils.js')
-rw-r--r-- | app/scripts/lib/stream-utils.js | 17 |
1 files changed, 8 insertions, 9 deletions
diff --git a/app/scripts/lib/stream-utils.js b/app/scripts/lib/stream-utils.js index ca245ca9a..1b7b89d14 100644 --- a/app/scripts/lib/stream-utils.js +++ b/app/scripts/lib/stream-utils.js @@ -1,36 +1,35 @@ const Through = require('through2') const ObjectMultiplex = require('./obj-multiplex') - module.exports = { jsonParseStream: jsonParseStream, jsonStringifyStream: jsonStringifyStream, setupMultiplex: setupMultiplex, } -function jsonParseStream(){ - return Through.obj(function(serialized, encoding, cb){ +function jsonParseStream () { + return Through.obj(function (serialized, encoding, cb) { this.push(JSON.parse(serialized)) cb() }) } -function jsonStringifyStream(){ - return Through.obj(function(obj, encoding, cb){ +function jsonStringifyStream () { + return Through.obj(function (obj, encoding, cb) { this.push(JSON.stringify(obj)) cb() }) } -function setupMultiplex(connectionStream){ +function setupMultiplex (connectionStream) { var mx = ObjectMultiplex() connectionStream.pipe(mx).pipe(connectionStream) - mx.on('error', function(err) { + mx.on('error', function (err) { console.error(err) }) - connectionStream.on('error', function(err) { + connectionStream.on('error', function (err) { console.error(err) mx.destroy() }) return mx -}
\ No newline at end of file +} |