index.js
function($done) {
  function procType(kv, $_done) {
    var jobType=kv[0], func=kv[1]
    JOBS.process(jobType, func._concurrent, func)
    $_done()
  }

  // TODO: wouldn't need to do this if async.forEach() took an object
  var _procs = _.zip(_.keys(__processors), _.values(__processors))

  async.forEach(_procs, procType, function(err) {
    if (err) return $done(err);
    __running.process = true
    $done()
  })
}
function($done) {
  function procType(kv, $_done) {
    var jobType=kv[0], func=kv[1]
    JOBS.process(jobType, func._concurrent, func)
    $_done()
  }

  // TODO: wouldn't need to do this if async.forEach() took an object
  var _procs = _.zip(_.keys(__processors), _.values(__processors))

  async.forEach(_procs, procType, function(err) {
    if (err) return $done(err);
    __running.process = true
    $done()
  })
}
function ( $done ) { function procType ( kv , $_done ) { var jobType = kv [ 0 ] , func = kv [ 1 ] JOBS . process ( jobType , func . _concurrent , func ) $_done ( ) } // TODO: wouldn't need to do this if async.forEach() took an object var _procs = _ . zip ( _ . keys ( __processors ) , _ . values ( __processors ) ) async . forEach ( _procs , procType , function ( err ) { if ( err ) return $done ( err ) ; __running . process = true $done ( ) } ) }
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ ~~ Util Functions
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ ~~ Util Functions