ex.js

var stream = require('stream');  

function dosomething() {
    var out = new stream.PassThrough();
    out.write('two');
    return out;
}
 
var source = new stream.PassThrough()
 
source.pipe(dosomething()).pipe(process.stdout)
 
source.write('one')