1var split = require('split'); 2var wrap = require('../'); 3var through = require('through2'); 4 5process.stdin.pipe(wrap.obj(split())).pipe(through.obj(write)); 6 7function write (buf, enc, next) { 8 console.log(buf.length + ': ' + buf); 9 next(); 10} 11 12