completion-queue.js

"use strict";
var Queue = require( "./queue" );

var CompletionQueue = function () {
	Queue.apply( this, arguments );
	this.flushCount = 0;
};
CompletionQueue.prototype = Object.create( Queue.prototype );
CompletionQueue.prototype.constructor = CompletionQueue;

CompletionQueue.prototype.flush = function () {
	if ( this.flushCount === 0 ) {
		this.flushCount ++;
		while ( this.index < this.tasks.length ) {
			var task = this.tasks[this.index++];

			if (process.env.NODE_ENV !== 'production') {
				this._logFlush( task );
			}

			task.fn.apply( task.context, task.args );
		}
		this.index = 0;
		this.tasks = [];
		this.flushCount--;
		this.callbacks.onComplete( this );
	}
};

module.exports = CompletionQueue;