dispatchWaitingEvents method

void dispatchWaitingEvents()

Implementation

void dispatchWaitingEvents() {
  int nextExpectedSequenceId = _currentSequenceId + 1;

  while (waitingEvents.containsKey(nextExpectedSequenceId)) {
    _currentSequenceId = nextExpectedSequenceId;

    final nextEvent = waitingEvents.remove(_currentSequenceId)!;
    onReceive(nextEvent);

    nextExpectedSequenceId = _currentSequenceId + 1;
  }
}