keep-alive-agent.js

"use strict";

var _            = require("underscore")
  , ForeverAgent = require("request/forever");

exports.createKeepAliveAgent = function createKeepAliveAgent() {
  var agent = new ForeverAgent();

  agent.close = function close() {
    var self = this;
    _.each(self.sockets, function (value, key) {
      self.sockets[key].forEach(function (socket) {
        socket.destroy();
      });
    });
  };

  agent.minSockets = 1000;

  return agent;
};