httpreqstreams.js

httpreqstreams.js

// Works (console.logs the headers)
require('http').request('http://www.google.com')
  .on('response', function (response) {
    console.log(response.headers);
  })
  .end();

// Doesn't work (hangs)
require('http').request('http://www.google.com')
  .on('response', function (response) {
    console.log(response.headers)
  })
  .pipe(require('through2')()) // this should just be a simple passtrhough.... why doesn't it work?
  .end();

timing_classic.js

function logTiming(req) {
  var start = Date.now();
  req.on('response', function (response) {
    // Log response timing for example
    console.log(Date.now() - start);
    response.resume();
  });
  return req;
}

logTiming(require('http').request('http://www.google.com'))
  .on('response', function (response) {
    console.log(response.headers)
  })
  .end();

timing_pipe.js

var passThroughWithEvents = require('through2')();
passThroughWithEvents.on('pipe', function (req) {
  var start = Date.now();
  req.on('response', function (response) {
    // Log response timing for example
    console.log(Date.now() - start);
    response.resume();
  });
});

require('http').request('http://www.google.com')
  .on('response', function (response) {
    console.log(response.headers)
  })
  .pipe(passThroughWithEvents)
  .end();