var tr = require('trumpet')(); tr.createReadStream('article > span') .pipe(process.stdout); var request = require('request'); request.get('http://www.echojs.com').pipe(tr);