failAllPendingRequests method

void failAllPendingRequests(
  1. String reason
)

Implementation

void failAllPendingRequests(String reason) {
  final entries = _pendingRequests.entries.toList();
  for (var entry in entries) {
    final requestId = entry.key;
    final pending = entry.value;
    pending.dispose();
    if (pending.hasOptimisticChanges) {
      _mutationHandler?.onRollbackOptimistic(requestId.toString());
    }
    pending.completer.completeError(
      SpacetimeDbConnectionException(
        'Connection lost during reducer call: $reason',
      ),
    );
  }
  _pendingRequests.clear();
  _requestIdByUuid.clear();
}