DelayStream

gistfile1.txt

var Transform = require('stream').Transform,
    http = require('http');

function DelayStream () {
    Transform.apply(this, arguments);
}
DelayStream.prototype = Object.create(Transform.prototype);
DelayStream.prototype._transform = Transform.prototype.push;


function get(options) {
    var stream = new DelayStream();

    http.get(options, function (res) {
        res.pipe(stream);
    }); 
    
    return stream;
}   


get('http://google.com')
    .on('data', function (chunk) {
        console.log(chunk);
    })  
    .on('end', function () {
        console.log('done');
    });