through stream

inde.js

var through = require('through');
var split = require('split');

var a = through(function write(data) {
  // We handle the data internally here
  this.queue('line: ' + data + '\n');
});
a.pipe(process.stdout);

var exposed = through();
exposed.pipe(split()).pipe(a);


// some other stream
var b = through(function write(data) {
  // do something with b data here
  this.queue(data);
});


exposed.write('omg test 123\nomg test 456\nomg test 789\n');

b.pipe(exposed);
b.write('omg test 1313213456\n');