dispose method

void dispose()

Forget in-flight requests (the coordinator is stopping).

Implementation

void dispose() {
  _pending.clear();
  for (final waiter in _awaitingVerdict.values) {
    if (!waiter.isCompleted) {
      waiter.completeError(StateError('the coordinator stopped before the receive path answered'));
    }
  }
  _awaitingVerdict.clear();
}