Interface IFlowSignalDispatcher

Namespace

FlowOrchestrator.Core.Execution

Assembly

FlowOrchestrator.Core.dll

Application-facing entry point for delivering signals to parked WaitForSignal steps. Used by the dashboard signal endpoint and by tests/applications that prefer not to talk to HTTP.

public interface IFlowSignalDispatcher

Methods

DispatchAsync(Guid, string, string, CancellationToken)

Validates the run, persists the payload on the matching waiter, and nudges the engine to re-execute the parked step so it observes the delivered payload.

ValueTask<SignalDeliveryResult> DispatchAsync(Guid runId, string signalName, string payloadJson, CancellationToken ct = default)

Parameters

runId Guid

The run whose WaitForSignal step should receive the signal.

signalName string

Logical signal name configured on the step's signalName input.

payloadJson string

Pre-serialised JSON payload supplied by the caller.

ct CancellationToken

Cancellation token.

Returns

ValueTask<SignalDeliveryResult>