gistfile1.js

var eventAccumulator = function(event, eventsList, queue, callback) {
	// logger.log("arena","eventAccumulator(%s,%s,%s,callback)",event, JSON.stringify(eventsList), JSON.stringify(queue));
	logger.log("arena","eventAccumulator queue: " + queue + " event: " + event);
	if (typeof eventAccumulator[queue] === 'undefined' || typeof eventAccumulator[queue].eventList === 'undefined') {
		eventAccumulator[queue] = {};
		eventAccumulator[queue].eventList = [];
		for (var i in eventsList) {
			eventAccumulator[queue].eventList.push(eventsList[i])
		}
	}
	eventAccumulator[queue].eventList = _.without(eventAccumulator[queue].eventList, event);
	logger.log("arena","Still waiting for events: " + JSON.stringify(eventAccumulator[queue].eventList));
	if (eventAccumulator[queue].eventList.length == 0) {
		delete(eventAccumulator[queue]);
		logger.log("arena","Calling callback for queue " + queue);
		callback();
	}
};