in src/main/java/com/amazonaws/services/simpleworkflow/flow/worker/DecisionsHelper.java [519:536]
public void handleDecisionTaskStartedEvent() {
int count = 0;
Iterator<DecisionStateMachine> iterator = decisions.values().iterator();
DecisionStateMachine next = null;
DecisionStateMachine decisionStateMachine = getNextDecision(iterator);
while (decisionStateMachine != null) {
next = getNextDecision(iterator);
if (++count == MAXIMUM_DECISIONS_PER_COMPLETION && next != null && !isCompletionEvent(next.getDecision())) {
break;
}
decisionStateMachine.handleDecisionTaskStartedEvent();
decisionStateMachine = next;
}
if (next != null && count < MAXIMUM_DECISIONS_PER_COMPLETION) {
next.handleDecisionTaskStartedEvent();
}
}