diff options
Auto linted
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 +} |