src/promissory-arbiter.js
function resumeSubscriptionDispatcher (
    topic, data, options, subscriptions, resolver, fulfill, reject
  ) {
    var
      promise = resolver.promise,

      subscription;

    for (
      ;
      resolver.i >= 0 && promise.pending < options.semaphor;
      resolver.i -= 1
    ) {
      subscription = subscriptions[resolver.i];
      if (!subscription.suspended) {
        promise.pending += 1;
        subscriptionInvoker(subscription, data, topic).then(fulfill, reject);
      }
    }
  }
function resumeSubscriptionDispatcher (
    topic, data, options, subscriptions, resolver, fulfill, reject
  ) {
    var
      promise = resolver.promise,

      subscription;

    for (
      ;
      resolver.i >= 0 && promise.pending < options.semaphor;
      resolver.i -= 1
    ) {
      subscription = subscriptions[resolver.i];
      if (!subscription.suspended) {
        promise.pending += 1;
        subscriptionInvoker(subscription, data, topic).then(fulfill, reject);
      }
    }
  }
function resumeSubscriptionDispatcher ( topic , data , options , subscriptions , resolver , fulfill , reject ) { var promise = resolver . promise , subscription ; for ( ; resolver . i >= 0 && promise . pending < options . semaphor ; resolver . i -= 1 ) { subscription = subscriptions [ resolver . i ] ; if ( ! subscription . suspended ) { promise . pending += 1 ; subscriptionInvoker ( subscription , data , topic ) . then ( fulfill , reject ) ; } } }
Invokes the next set of subscriptions
Invokes the next set of subscriptions