shutdown method

Implementation

void shutdown() {
  for (final timer in _batchTimers.values) {
    timer.cancel();
  }
  _batchTimers.clear();

  // Fail all pending requests
  for (final requests in _pendingRequests.values) {
    for (final request in requests) {
      request.completer.complete(CFResult.error(
        'Pipeline shutdown',
      ));
    }
  }
  _pendingRequests.clear();
}