task manager

task_manager_snip.js

  TaskManager.prototype.handle = function(result) {
    var emitter, emitters, task_id, tm, _results;
    tm = this;
    if (result.identifier) {
      if ((emitters = this.matchatron.take(result))) {
        _results = [];
        for (task_id in emitters) {
          emitter = emitters[task_id];
          if (result.error) {
            _results.push(emitter.emit("error", result.error, result));
          } else if (result.timeout) {
            _results.push(emitter.emit("timeout"));
          } else {
            _results.push(emitter.emit("success", result));
          }
        }
        return _results;
      } else {
        return logger.debug("Received result with unmatchable identifier");
      }
    } else {
      logger.warn("Received result with no identifier");
      return logger.debug(JSON.stringify(result));
    }
  };