collect-callbacks
Aggregate many callbacks into one
Synopsis
var collect = require('collect-callbacks');
collect.all( function(aggregate) {
setTimeout(aggregate(function(){ console.log("two") }),2000);
setTimeout(aggregate(function(){ console.log("three") }),3000);
}, function (err, args) {
// This won't execute until both of the timeouts above have completed
});
collect.all( function(aggregate) {
setImmediate(aggregate(),'test','this');
setImmediate(aggregate(),1,2,3);
}, function (err, args) {
// args is an an array of arguments objects, the first with
// ['test,'this'] and the second with [1,2,3]
});
collect.all( function(aggregate) {
setImmediate(aggregate(),'test','this');
setImmediate(aggregate(),1,2,3);
}.then(args) {
// args is an an array of arguments objects, the first with
// ['test,'this'] and the second with [1,2,3]
});
collect.any( function(aggregate) {
setTimeout(aggregate(function(){ console.log("two") }),2000);
setTimeout(aggregate(function(){ console.log("three") }),3000);
}, function (err, args) {
// This will be called as soon as the shorter timer triggers.
// Note that the longer one will still trigger, just after this is executed.
});
Description
Reduce a group of unrelated callbacks into a single callback. Either when the first event is emitted, or after all callbacks have been emitted at least once.
Functions
var collect = require('collect-callbacks');
- collect.all( setup[, alldone] )[ -> Promise]
setup is a function with a signature of (event) that should setup whatever
event listeners you want to be aggregated into the collection. The event
argument is a function with a signature of ([listener]) that you should call
to generate event handlers that will be part of this aggregation. You can
optionally pass through your usual callback function in the listener argument.
collect.all will call alldone (if passed) and fullfill the Promise when ALL of the callbacks associated with it have triggered at least once.
The promise is resolved with the arguments of all of the callbacks it collected.
- collect.any( setup[, alldone] )[ -> Promise]
Like collect.all but it triggers on the first of any of the aggregated callbacks to complete.