ewait

WaitForAll and WaitForAny on EventEmitter.

WaitForAll and WaitForAny for Node.js EventEmitter

WaitForAll and WaitForAny on EventEmitter instances.

npm install ewait
npm test

WaitForAny will wait until one of the specified EventEmitter is done. By contrast, WaitForAll will wait until all of the specified EventEmitter are done.

Upon successful completion, they will both emit a done event. On timeout, a timeout event will be emitted.

By default, WaitForAny and WaitForAll listen for the done event. This behavior can be altered by specifying a custom event type.

var all = new WaitForAll({
    timeout: 2000,      // Wait for 2000ms max. 
    event: 'flushed'    // Wait for a custom event. 
});
 
all.add([toilet1, toilet2, toilet3]);
 
all.once('done', function() {
    console.log('All done!');
});
 
all.once('timeout', function() {
    console.log('Timeout!');
});
 
all.wait();
var toilets = [toilet1, toilet2, toilet3];
 
ewait.waitForAll(toilets, function(err) {
    console.log(err ? 'Timeout!' : 'Done!');
}, 2000, 'flushed');

Construct a new wait object with an 'AND' semantic.

options is an object with the following defaults:

options = {
    timeout: -1,  // No timeout. 
    event: 'done' // Listen for 'done' events. 
};
  • emitters: an array of EventEmitter

Add EventEmitter instances to wait on. Shouldn't be called after wait.

Start waiting on EventEmitter instances.

  • results: the results returned by the EventEmitters

Emitted when the waiting criterion has been satisfied before timeout.

Emitted when timeout expires before waiting criterion is satisfied.

Construct a new wait object with an 'OR' semantic.

options is an object with the following defaults:

options = {
    timeout: -1,  // No timeout. 
    event: 'done' // Listen for 'done' events. 
};
  • emitters: an array of EventEmitter

Add EventEmitter instances to wait on. Shouldn't be called after wait.

Start waiting on EventEmitter instances.

  • index: the index of the EventEmitter that has fired
  • args...: the parameters returned by the EventEmitter

Emitted when the waiting criterion has been satisfied before timeout.

Emitted when timeout expires before waiting criterion is satisfied.

  • emitters: an array of EventEmitter
  • callback: continuation callback
  • event: the event name, defaults to 'done'
  • timeout: the timeout delay, defaults to -1

event defaults to done and timeout defaults to undefined.

The callback takes two arguments, err and results.

  • err: is null on successful wait and contains an error on timeout
  • results: the results returned by the EventEmitters

Behavior is the same as WaitForAll.

See ewait.waitForAll for arguments.

Behavior is the same as WaitForAny.

This code is free to use under the terms of the MIT license.