async_function_queue.js

propublica.models.AsyncFunctionQueue = propublica.Model.extend({
  stopped : false,
  init : function(attrs){
    this.queue = [];
    this._super(attrs);
  },
  
  add : function(fn){
    this.queue.push(fn);
    this._run();
  },
  
  start : function(){
    this.stopped = false;
    _.delay(_.bind(this._run, this), 50);
  },
  
  stop : function(){
    this.stopped = true;
  },
  
  _run : function(){
    if(!this.stopped && this.queue.length){
      this.queue.shift()();
      if(!this.stopped) this._run();
    }
  }
});