pipesnipet.js

'use strict'

const pipe_initialize = (ctx) => {
    process.stdin.resume();
    process.stdin.setEncoding('utf8');
    process.stdin.on('data', function(chunk){
        if (chunk == "") { return ;}
        var lines = chunk.split("\n");
        lines[0] = ctx.fragment + lines[0];
        ctx.fragment = lines.pop();
        lines.forEach(function(line){
            ctx.pipe(line);
        });
    });
    process.stdin.on('end', function(){
    });
}

const main = (argv) => {
    let ctx = {
        fragment : "",
        pipe : (line) => {console.log(line)}
    }
    pipe_initialize(ctx);
}

main(process.argv.slice(2));