var es = require('event-stream');

var streamLine = es.through(function (line) {
    this.queue("*");
    this.queue("|"+line+'\n');
});

process.stdin.on('readable', function() {
    var streamLine1 = es.through(function (line) {
        this.queue('*');
        this.queue("|"+line+'\n');
    });

    process.stdin.pipe(es.split()).pipe(streamLine).pipe(process.stdout);
})

$ printf "a\nb\n" | node pipeTest.js
*|a
*|b
**|
|