branch

va branch = require("branch"),
EventEmitter = require("events").EventEmitter;
 
 
//first give branch 
var chain = branch(EventEmitter);
chain.source([new EventEmitter(), new EventEmitter()]);
 
//called twice - once per each event emitter
chain.on("hello-world", function(event) {
  
});
 
//called against each event emitter
chain.emit("hello-world");

var chain = branch({})

 
//using a class
var chain = branch(EventEmitter);
chain.on("hello-world", function(){});
 
 
//using an object or prototype
chain = branch({
    "helloWorld": function() {
 
    }
});
 
chain.helloWorld();
 
//using an array
chain = branch(['helloWorld']);
chain.helloWorld();

var chain = branch(EventEmitter).
pre("on", function(type, callback, next) {
  next("prefix-" + type, callback);
}).
source([new EventEmitter()]);
 
 
//actual listener 
chain.on("hello", function() {
  
});
 
 
chain.emit("prefix-hello", "world!");

var chain = branch(Array);
chain.source([1], [2], [3], [4]);
 
chain.map(function(n) {
  return n + 1;
}).async(function(err, values) {
  console.log(values);
})

var chain = branch(Array);
chain.add([1],[2],[3],[4]);
var result = chain.map(function(n) {
  return n + 1;
}).sync();
 
console.log(result); //[2], [3], [4], [5]