lib/kafkaesque.js
function() {
    if (_polling) {
      _closing = true;
      setTimeout(function() {
        if( _closing) {
          _.each(_brokers, function(broker) {
            broker.tearDown();
          });
        }
      }, _options.maxWait);
    }
    else {
      _.each(_brokers, function(broker) {
        broker.tearDown();
      });
    }
  }
function() {
    if (_polling) {
      _closing = true;
      setTimeout(function() {
        if( _closing) {
          _.each(_brokers, function(broker) {
            broker.tearDown();
          });
        }
      }, _options.maxWait);
    }
    else {
      _.each(_brokers, function(broker) {
        broker.tearDown();
      });
    }
  }
function ( ) { if ( _polling ) { _closing = true ; setTimeout ( function ( ) { if ( _closing ) { _ . each ( _brokers , function ( broker ) { broker . tearDown ( ) ; } ) ; } } , _options . maxWait ) ; } else { _ . each ( _brokers , function ( broker ) { broker . tearDown ( ) ; } ) ; } }
end all polls and teardown all connections to kafka
end all polls and teardown all connections to kafka