ProcessEvent

为事件流程添加分支结构和回溯功能

Example

ProcessEvent(function(){
  console.log('start');

  this.emit('1', 1);
}).register('1', function(d){
  console.log(1, d);

  if(d == 1)
    this.emit('2', 2);
  else
    throw new Error('end');
}).register('2', function(d){
  console.log(2, d);

  this.emit('1', 3);
}).catch(function(error){
  console.log(error);
});

// out put
// start
// 1, 1
// 2, 2
// 1, 3
// Error: end

对比 Promise 链式结构

new Promise(function(resolve){
  console.log('start');

  resolve(1);
}).then(function(d){
  console.log(1, d);

  resolve(2)
}).then(function(d){
  console.log(2, d);

  resolve(3);
}).then(function(d){
  console.log(1, d);

  throw new Error('end');
}).catch(function(error){
  console.log(error);
});

// out put
// start
// 1, 1
// 2, 2
// 1, 3
// Error: end

Promise 的链式结构类似一条主线从头走到尾，事件没有分支处理，走过的流程无法回溯，只能再之后重新进行。

远程调用

var p1 = ProcessEvent(function(){
  console.log('i am p1');
}).register('a', function(d){
  console.log('p1-a', d);
  this.emit('b', 'p1-b');
}).register('b', function(d){
  console.log('p1-b', d);
  this.emit('c', 'p1-c');
}).register('c', function(d){
  console.log('p1-c', d);
});

var p2 = ProcessEvent(function(){
  console.log('i am p2');
  this.emit('a', 'p2-a');
}).register('a', function(d){
  console.log('p2-a', d);
  this.emit(p1, 'b', 'p2-b');
});

// out put
// i am p1
// i am p2
// p2-a p2-a
// p1-b p2-b
// p1-c p1-c