cleanUp method

void cleanUp()

Implementation

void cleanUp() {
  _ackTimers.removeWhere((key, value) => true);
  _queue.cleanUp();
  clearCompleters();
}