Created to simplify flow management when programming in asynchronous environments like nodejs.
CauseEffect extends EventEmitter and allows to set cause-effect scenarios.
It is simple yet effective.
CauseEffect allows you to:
* have an event fired when multiple parallel flows complete.
* easily unite multiple parallel flows initiated from the for loop.
* set up chains: completion of one rule may trigger another.
* set the rules dynamically or statically.
* have an event fired when any of the flows completes.
To run example:
node examples/sample.js
Installation: npm install causeeffect
Usage: To setup a rule where an event will fire if all of the causes happen: ce.setEvents("myevent", ["cause1", "cause2", "cause3"]);
To setup a rule where an event will fire if some of the causes happen:
ce.setEvents("myevent", ["cause1", "cause2", "cause3"], true);
To setup a rule where an event will fire if it happens X times:
ce.setEvents("myevent", 10);
Listen to effect event as usual with EventEmitter API:
ce.on("myevent", callback);
To let CauseEffect know that the cause has happened call:
ce.setState("cause1");
or if you need a specific value use
ce.setState("cause1", value);
This value can be then obtained from your event callback with:
ce.getState("cause1")
To run example:
node examples/sample.js
Sample:
-
Uniting multiple parallel flows initiated from the for loop: var ce = require('causeeffect'); ce = new ce.CauseEffect();
// Set up ticker cause. Event "myticker" will fire if ce.setState("myticker") was invoked 4 times. // Handy for figuring out when all callbacks have been called initiated from the for loop. ce.setEvents("myticker", 4);
function callback() { ce.setState("myticker"); }
for(var i = 0; i< 4; i++) { setTimeout(callback, 100); }
ce.on("myticker", function() { });
-
Uniting specific parallel flows // Set up AND cause effect. Event "alldone" will be fired if all of causes happen ce.setEvents("alldone", ["cause1", "cause2", "myticker"]);
// Listen to event as usual with EventEmitter API ce.on("alldone", function() { });
// To let CauseEffect know that the cause has happened ce.setState("cause1"); ce.setState("cause2");