loadPendingSignals method

@override Future<List<WorkflowSignal>> loadPendingSignals(String workflowExecutionId, { String? signalName, })

Loads all pending signals for a given workflow execution and optional signal name filter.

Implementation

@override
Future<List<WorkflowSignal>> loadPendingSignals(
  String workflowExecutionId, {
  String? signalName,
}) async {
  return _signals.where((s) {
    if (s.workflowExecutionId != workflowExecutionId) return false;
    if (s.status != SignalStatus.pending) return false;
    if (signalName != null && s.signalName != signalName) return false;
    return true;
  }).toList();
}