yetangitu/epub.js
1
0
Fork 0
mirror of https://github.com/futurepress/epub.js.git synced 2025-10-03 14:59:18 +02:00
Code Issues Releases Wiki Activity

Tabify src

Browse source
This commit is contained in:
Fred Chasen 2016-10-24 15:15:16 +02:00
parent f6247e5612
commit 32993dc58c
31 changed files with 7759 additions and 7758 deletions
Download patch file Download diff file Expand all files Collapse all files

232
src/queue.js
View file

@ -2,191 +2,191 @@ var RSVP = require('rsvp');
var core = require('./core');
function Queue(_context){
this._q = [];
this.context = _context;
this.tick = core.requestAnimationFrame;
this.running = false;
this.paused = false;
this._q = [];
this.context = _context;
this.tick = core.requestAnimationFrame;
this.running = false;
this.paused = false;
};
// Add an item to the queue
Queue.prototype.enqueue = function() {
var deferred, promise;
var queued;
var task = [].shift.call(arguments);
var args = arguments;
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(!task) {
return console.error("No Task Provided");
}
// Handle single args without context
// if(args && !Array.isArray(args)) {
// args = [args];
// }
if(!task) {
return console.error("No Task Provided");
}
if(typeof task === "function"){
if(typeof task === "function"){
deferred = new RSVP.defer();
promise = deferred.promise;
deferred = new RSVP.defer();
promise = deferred.promise;
queued = {
"task" : task,
"args" : args,
//"context" : context,
"deferred" : deferred,
"promise" : promise
};
queued = {
"task" : task,
"args" : args,
//"context" : context,
"deferred" : deferred,
"promise" : promise
};
} else {
// Task is a promise
queued = {
"promise" : task
};
} else {
// Task is a promise
queued = {
"promise" : task
};
}
}
this._q.push(queued);
this._q.push(queued);
// Wait to start queue flush
if (this.paused == false && !this.running) {
// setTimeout(this.flush.bind(this), 0);
// this.tick.call(window, this.run.bind(this));
this.run();
}
// Wait to start queue flush
if (this.paused == false && !this.running) {
// setTimeout(this.flush.bind(this), 0);
// this.tick.call(window, this.run.bind(this));
this.run();
}
return queued.promise;
return queued.promise;
};
// Run one item
Queue.prototype.dequeue = function(){
var inwait, task, result;
var inwait, task, result;
if(this._q.length) {
inwait = this._q.shift();
task = inwait.task;
if(task){
// console.log(task)
if(this._q.length) {
inwait = this._q.shift();
task = inwait.task;
if(task){
// console.log(task)
result = task.apply(this.context, inwait.args);
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;
}
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 if(inwait.promise) {
// Task is a promise
return inwait.promise;
}
} else {
inwait = new RSVP.defer();
inwait.deferred.resolve();
return inwait.promise;
}
} else {
inwait = new RSVP.defer();
inwait.deferred.resolve();
return inwait.promise;
}
};
// Run All Immediately
Queue.prototype.dump = function(){
while(this._q.length) {
this.dequeue();
}
while(this._q.length) {
this.dequeue();
}
};
// Run all sequentially, at convince
Queue.prototype.run = function(){
if(!this.running){
this.running = true;
this.defered = new RSVP.defer();
}
if(!this.running){
this.running = true;
this.defered = new RSVP.defer();
}
this.tick.call(window, function() {
this.tick.call(window, function() {
if(this._q.length) {
if(this._q.length) {
this.dequeue()
.then(function(){
this.run();
}.bind(this));
this.dequeue()
.then(function(){
this.run();
}.bind(this));
} else {
this.defered.resolve();
this.running = undefined;
}
} else {
this.defered.resolve();
this.running = undefined;
}
}.bind(this));
}.bind(this));
// Unpause
if(this.paused == true) {
this.paused = false;
}
// Unpause
if(this.paused == true) {
this.paused = false;
}
return this.defered.promise;
return this.defered.promise;
};
// Flush all, as quickly as possible
Queue.prototype.flush = function(){
if(this.running){
return this.running;
}
if(this.running){
return this.running;
}
if(this._q.length) {
this.running = this.dequeue()
.then(function(){
this.running = undefined;
return this.flush();
}.bind(this));
if(this._q.length) {
this.running = this.dequeue()
.then(function(){
this.running = undefined;
return this.flush();
}.bind(this));
return this.running;
}
return this.running;
}
};
// Clear all items in wait
Queue.prototype.clear = function(){
this._q = [];
this.running = false;
this._q = [];
this.running = false;
};
Queue.prototype.length = function(){
return this._q.length;
return this._q.length;
};
Queue.prototype.pause = function(){
this.paused = true;
this.paused = true;
};
// Create a new task from a callback
function Task(task, args, context){
return function(){
var toApply = arguments || [];
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);
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);
// Apply all arguments to the functions
task.apply(this, toApply);
}.bind(this));
}.bind(this));
};
};
};