src/notifier.js
function handleNotifyNext(e) {
  if (notifyOfNextSubs[e.type].length === 0) return;
  e.persist = blankFunction;
  const reNotifyOfNext = [];
  const reNotifyOfNextIDs = {};
  notifyOfNextSubs[e.type].forEach(sub => {
    if (sub.callback(e) === 'reNotifyOfNext') {
      reNotifyOfNextIDs[sub.id] = reNotifyOfNext.push(sub) - 1;
    }
  });
  notifyOfNextSubs[e.type] = reNotifyOfNext;
  subsIDs[e.type] = reNotifyOfNextIDs;
}
function handleNotifyNext(e) {
  if (notifyOfNextSubs[e.type].length === 0) return;
  e.persist = blankFunction;
  const reNotifyOfNext = [];
  const reNotifyOfNextIDs = {};
  notifyOfNextSubs[e.type].forEach(sub => {
    if (sub.callback(e) === 'reNotifyOfNext') {
      reNotifyOfNextIDs[sub.id] = reNotifyOfNext.push(sub) - 1;
    }
  });
  notifyOfNextSubs[e.type] = reNotifyOfNext;
  subsIDs[e.type] = reNotifyOfNextIDs;
}
function handleNotifyNext ( e ) { if ( notifyOfNextSubs [ e . type ] . length === 0 ) return ; e . persist = blankFunction ; const reNotifyOfNext = [ ] ; const reNotifyOfNextIDs = { } ; notifyOfNextSubs [ e . type ] . forEach ( sub => { if ( sub . callback ( e ) === 'reNotifyOfNext' ) { reNotifyOfNextIDs [ sub . id ] = reNotifyOfNext . push ( sub ) - 1 ; } } ) ; notifyOfNextSubs [ e . type ] = reNotifyOfNext ; subsIDs [ e . type ] = reNotifyOfNextIDs ; }
notify next when event comes, if the callback returns 'reNotifyOfNext', then re-subscribe using the same id
notify next when event comes if the callback returns reNotifyOfNext then re - subscribe using the same id