URL fetching wrapper for feedparser v.16

wrapper.js

var FeedParser = require('feedparser')
  , request = require('request')
  , STATUS_CODES = require('http').STATUS_CODES;

module.exports = function (feed, cb) {
  var parser = new FeedParser();
  var req = request(feed);
  var items = [];

  var _called = false;

  req.on('error', function (err) {
    if (!_called) {
      _called = true;
      cb(err);
    }
  });

  req.on('response', function (response) {
    if (200 !== response.statusCode) {
      var err = new Error(STATUS_CODES[response.statusCode]);
      err.code = response.statusCode;
      parser.end();
      if (!_called) {
        _called = true;
        cb(err);
      }
    }
  });

  parser.on('error', function (err) {
    if (!_called) {
      _called = true;
      cb(err);
    }
  });

  parser.on('readable', function () {
    var stream = this, item;
    while (item = stream.read()) {
      // items.push(item);
    }
  });

  parser.on('end', function () {
    if (!_called) {
      _called = true;
      cb(null, items);
    }
  });

  return req.pipe(parser);
};

Thanks for the unpiping link. It seems all of my superfluous emitting problems are solved with this latching technique. Do you think it is also prudent to unpipe at the first error?