queue.js

"use strict";
var queueState = require("./queue-state");
var canDev = require('can-log/dev/dev');
var assign = require("can-assign");

function noOperation () {}

var Queue = function ( name, callbacks ) {
	this.callbacks = assign( {
		onFirstTask: noOperation,

		onComplete: function () {
			queueState.lastTask = null;
		}
	}, callbacks || {});
	this.name = name;
	this.index = 0;
	this.tasks = [];
	this._log = false;
};

Queue.prototype.constructor = Queue;

Queue.noop = noOperation;

Queue.prototype.enqueue = function ( fn, context, args, meta ) {
	var len = this.tasks.push({
		fn: fn,
		context: context,
		args: args,
		meta: meta || {}
	});

	if(process.env.NODE_ENV !== 'production') {
		this._logEnqueue( this.tasks[len - 1] );
	}

	if ( len === 1 ) {
		this.callbacks.onFirstTask( this );
	}
};

Queue.prototype.flush = function () {
	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.callbacks.onComplete( this );
};

Queue.prototype.log = function () {
	this._log = arguments.length ? arguments[0] : true;
};

if(process.env.NODE_ENV !== 'production') {
	Queue.prototype._logEnqueue = function ( task ) {

		task.meta.parentTask = queueState.lastTask;

		task.meta.stack = this;

		if ( this._log === true || this._log === "enqueue" ) {
			var log = task.meta.log ? task.meta.log.concat( task ) : [task.fn.name, task];
			canDev.log.apply( canDev, [this.name + " enqueuing:"].concat( log ));
		}
	};

	Queue.prototype._logFlush = function ( task ) {
		if ( this._log === true || this._log === "flush" ) {
			var log = task.meta.log ? task.meta.log.concat( task ) : [task.fn.name, task];
			canDev.log.apply( canDev, [this.name + " running  :"].concat( log ));
		}

		queueState.lastTask = task;
	};
}

module.exports = Queue;