2016-04-08 23:24:10 +02:00
|
|
|
const Through = require('through2')
|
2017-09-08 06:17:49 +02:00
|
|
|
const ObjectMultiplex = require('obj-multiplex')
|
|
|
|
const pump = require('pump')
|
2016-04-08 23:24:10 +02:00
|
|
|
|
|
|
|
module.exports = {
|
|
|
|
jsonParseStream: jsonParseStream,
|
|
|
|
jsonStringifyStream: jsonStringifyStream,
|
2016-04-15 21:12:04 +02:00
|
|
|
setupMultiplex: setupMultiplex,
|
2016-04-08 23:24:10 +02:00
|
|
|
}
|
|
|
|
|
2016-06-21 22:18:32 +02:00
|
|
|
function jsonParseStream () {
|
|
|
|
return Through.obj(function (serialized, encoding, cb) {
|
2016-04-08 23:24:10 +02:00
|
|
|
this.push(JSON.parse(serialized))
|
|
|
|
cb()
|
|
|
|
})
|
|
|
|
}
|
|
|
|
|
2016-06-21 22:18:32 +02:00
|
|
|
function jsonStringifyStream () {
|
|
|
|
return Through.obj(function (obj, encoding, cb) {
|
2016-04-08 23:24:10 +02:00
|
|
|
this.push(JSON.stringify(obj))
|
|
|
|
cb()
|
|
|
|
})
|
|
|
|
}
|
2016-04-15 21:12:04 +02:00
|
|
|
|
2016-06-21 22:18:32 +02:00
|
|
|
function setupMultiplex (connectionStream) {
|
2017-09-08 06:17:49 +02:00
|
|
|
const mux = new ObjectMultiplex()
|
|
|
|
pump(
|
|
|
|
connectionStream,
|
|
|
|
mux,
|
|
|
|
connectionStream,
|
|
|
|
(err) => {
|
|
|
|
if (err) console.error(err)
|
|
|
|
}
|
|
|
|
)
|
|
|
|
return mux
|
2016-06-21 22:18:32 +02:00
|
|
|
}
|