acnalesso

var bb = new Backburner(['cook', 'prepare', 'serve']);
var food = { name: "" };

function cookFood(name) {
 console.log(name);
 food.name = name;
}

function prepareFood() {
 console.log('A chef is preparing your food!!!')

acnalesso

invoke: function(target, method, args, _, _errorRecordedForStack) {
 if (args && args.length > 0) {
  method.apply(target, args);
 } else {
  method.call(target);
 }
}

acnalesso

invokeWithOnError: function(target, method, args, onError, errorRecordedForStack) {
 try {
  if (args && args.length > 0) {
   method.apply(target, args);
  } else {
   method.call(target);
  }
 } catch(error) {
  onError(error, errorRecordedForStack);
 }

acnalesso

test("Queue#flush should be recursive if new items are added", function() {
 expect(2);
 
 var bb = new Backburner(['one']);
 var count = 0;
 
 bb.run(function(){
  function increment() {
   if (++count < 3) {
    bb.schedule('one', increment);

acnalesso

flush: {
 var queue = this._queue;
 var length = queue.length;
 
 if (length == 0) {
  return;
 }
 
 var globalOptions = this.globalOptions;
 var options = this.options;

acnalesso

Ember.run(function() {
 Ember.run.schedule('destroy', function() {
  Ember.run.schedule('actions', function() { console.log('actions'); });
  Ember.run.schedule('sync', function() { console.log('sync'); });
 });
});
 
// sync
// actions
 

acnalesso

var b = new Backburner(['sync', 'actions', 'destroy'], { ... });

b.run(function() {

 b.schedule('actions', function() { console.log('actions'); });
 
 b.schedule('sync', function() {
  console.log('flushing sync');
  b.schedule('actions', function() { console.log('actions schedduled in sync queue.'); });
 });

acnalesso

flush: function() {
  var queues = this.queues;
  var queueNames = this.queueNames;
  var queueName, queue, queueItems, priorQueueNameIndex;
  var queueNameIndex = 0;
  var numberOfQueues = queueNames.length;
  var options = this.options;
  
  while(queueNameIndex < numberOfQueues) {
    queueName = queueNames[queueNameIndex];

acnalesso

end: function() {
  var options = this.options;
  var onEnd = options && options.ondEnd;
  var currentInstance = this.currentInstance;
  var nextInstance = null;
  
  var finallyAlreadyCalled = false;
  
  try {
    currentInstance.flush();

acnalesso

run: function(target, method, /* options, arguments */) {
  var onError = getOnError(this.options);
  
  this.begin();
  
  if (!method) {
    method = target;
    target = null;
  }