takagotch / stream-combiner2 Goto Github PK

var combine = require('stream-combiner2')

var Combine = require('stream-combiner')
var es = require('event-stream')

Combine(
  process.openStdin(),
  es.split(),
  es.map(function(data, callback){
    var repr = inspect(JSON.parse(data))
    callback(null, repr)
  }),
  process.stdout
)