Flattened src dir

src/queue.js

@@ -0,0 +1,155 @@
+EPUBJS.Queue = function(_context){
+  this._q = [];
+  this.context = _context;
+  this.tick = EPUBJS.core.requestAnimationFrame;
+  this.running = false;
+};
+
+// Add an item to the queue
+EPUBJS.Queue.prototype.enqueue = function() {
+  var deferred, promise;
+  var queued;
+  var task = [].shift.call(arguments);
+  var args = arguments
+  
+  // Handle single args without context
+  // if(args && !Array.isArray(args)) {
+  //   args = [args];
+  // }
+  
+  if(typeof task === "function"){
+    
+    deferred = new RSVP.defer();
+    promise = deferred.promise;
+    
+    queued = {
+      "task" : task,
+      "args"     : args,
+      //"context"  : context,
+      "deferred" : deferred,
+      "promise" : promise
+    };
+    
+  } else {
+    // Task is a promise
+    queued = {
+      "promise" : task
+    };
+    
+  }
+  
+  this._q.push(queued);
+
+  // Wait to start queue flush
+  setTimeout(this.flush.bind(this), 0);
+
+  return queued.promise;
+};
+
+// Run one item
+EPUBJS.Queue.prototype.dequeue = function(){
+  var inwait, task, result;
+
+  if(this._q.length) {
+    inwait = this._q.shift();
+    task = inwait.task;
+    if(task){
+      // console.log(task)
+
+      result = task.apply(this.context, inwait.args);
+
+      if(result && typeof result["then"] === "function") {
+        // Task is a function that returns a promise
+        return result.then(function(){
+          inwait.deferred.resolve.apply(this.context, arguments);
+        }.bind(this));
+      } else {
+        // Task resolves immediately
+        inwait.deferred.resolve.apply(this.context, result);
+        return inwait.promise;
+      }
+
+      
+      
+    } else if(inwait.promise) {
+      // Task is a promise
+      return inwait.promise;
+    }
+
+  } else {
+    inwait = new RSVP.defer();
+    inwait.deferred.resolve();
+    return inwait.promise;
+  }
+
+};
+
+// Run All Immediately
+EPUBJS.Queue.prototype.dump = function(){
+  while(this._q.length) {
+    this.dequeue();
+  }
+};
+
+// Run all sequentially, at convince
+
+EPUBJS.Queue.prototype.run = function(){
+  if(!this.running && this._q.length) {
+    this.running = true;
+    this.dequeue().then(function(){
+      this.running = false;
+    }.bind(this));
+  }
+  
+  this.tick.call(window, this.run.bind(this));
+};
+
+// Flush all, as quickly as possible
+EPUBJS.Queue.prototype.flush = function(){
+  if(this.running){
+    return this.running;
+  }
+
+  if(this._q.length) {
+    this.running = this.dequeue().
+      then(function(){
+        this.running = undefined;
+        return this.flush();
+      }.bind(this));
+
+    return this.running;
+  }
+
+};
+
+// Clear all items in wait
+EPUBJS.Queue.prototype.clear = function(){
+  this._q = [];
+  this.running = false;
+};
+
+EPUBJS.Queue.prototype.length = function(){
+  return this._q.length;
+};
+
+// Create a new task from a callback
+EPUBJS.Task = function(task, args, context){
+
+  return function(){
+    var toApply = arguments || [];
+    
+    return new RSVP.Promise(function(resolve, reject) {
+      var callback = function(value){
+        resolve(value);
+      };
+      // Add the callback to the arguments list
+      toApply.push(callback);
+
+      // Apply all arguments to the functions
+      task.apply(this, toApply);
+    
+  }.bind(this));
+
+  };
+
+};