Priority Chain

With Priority-Chain, you can emit events in order of priorty, allowing each subscriber to mutate the value.

Example

'use strict';
const PriorityChain = require('priority-chain');

destiny = {};

const chain = new PriorityChain();

function timesTwo (event) {
  return event * 2;
}

function blocker (event) {
  return;
}

chain.subscribe('set', 10, timesTwo);

chain.subscribe('set', 0, (event) => {
  return event + 8;
});


chain.setLast('set', function (event) {
  this.out = event;
  return event;
}, destiny);

chain.setFirst('set', (event) => {
  return 0;
});

console.log(chain.emit('set', 123)); // 16

chain.subscribe('set', 5, blocker);

console.log(chain.emit('set', 34)); // 8

chain.unsubscribe('set', blocker);

console.log(chain.emit('set', 123)); // 16

chain.unsubscribe('set', timesTwo);

console.log(chain.emit('set', 123)); // 8

chain.setLast('set', function (event) {
  this.output = event;
  return event;
}, destiny);

console.log(chain.emit('set', 123)); // 8
console.log(destiny.output); // 8

Usage

subscribe(name, priority, function, ctx)

unsubscribe(name, function)

setFirst(name, function, ctx)

setLast(name, function, ctx)

emit(name, event)

If you return nothing or undefined, the event blocks the rest of the chain.