You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
36 lines
788 B
36 lines
788 B
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){
|
|
this.push(JSON.parse(serialized))
|
|
cb()
|
|
})
|
|
}
|
|
|
|
function jsonStringifyStream(){
|
|
return Through.obj(function(obj, encoding, cb){
|
|
this.push(JSON.stringify(obj))
|
|
cb()
|
|
})
|
|
}
|
|
|
|
function setupMultiplex(connectionStream){
|
|
var mx = ObjectMultiplex()
|
|
connectionStream.pipe(mx).pipe(connectionStream)
|
|
mx.on('error', function(err) {
|
|
console.error(err)
|
|
})
|
|
connectionStream.on('error', function(err) {
|
|
console.error(err)
|
|
mx.destroy()
|
|
})
|
|
return mx
|
|
} |