var Stream = require('stream'); var src = new Stream();src.readable = true; var dest = new Stream();dest.writable = true;dest.write = function(data) {  assert(data == 'test');}; src.pipe(dest); src.emit('data', 'test');