node.js v0.10. StreamV2. duplex stream

nodejs-v0.10-duplex-stream-pipe.js

var stream = require('stream');
var dest = new stream.Duplex, dest2 = new stream.Duplex;

dest._read = function(size) {};
dest._write = function(chunk, encoding, cb) {
  this.push(chunk.toString().toUpperCase());
  cb();
};

dest2._read = function(size) {};
dest2._write = function(chunk, encoding, cb) {
  var a = Buffer.concat([chunk, new Buffer("--- @We.pipe(Node).pipe('essential').pipe(You)\n")]);
  this.push(a);
  cb(null);
};
dest2.on('error', function() {
  console.log(arguments);
});

process.stdin
  .pipe(dest)
  .pipe(dest2)
  .pipe(process.stdout)