restorePendingSignals method

Future<void> restorePendingSignals(
  1. String workflowExecutionId
)

Restores pending signals from the store after a process restart.

Re-creates completers for any PENDING signals so that resumed workflows can await them again.

Implementation

Future<void> restorePendingSignals(String workflowExecutionId) async {
  final signals = await _store.loadPendingSignals(workflowExecutionId);
  for (final signal in signals) {
    final key = _compositeKey(workflowExecutionId, signal.signalName);
    if (!_completers.containsKey(key)) {
      _completers[key] = Completer<Object?>();
    }
  }
}