WorkflowContextImpl class

Concrete implementation of WorkflowContext.

Delegates step execution to StepExecutor for checkpoint/resume semantics. sleep() uses TimerManager for durable timers. waitSignal() uses SignalManager for durable signal handling.

Implemented types

Constructors

WorkflowContextImpl({required StepExecutor executor, required TimerManager timerManager, required SignalManager signalManager, required String workflowExecutionId})
Creates a WorkflowContextImpl.

Properties

executionId String
The unique identifier for this workflow execution.
no setteroverride
hashCode int
The hash code for this object.
no setterinherited
runtimeType Type
A representation of the runtime type of the object.
no setterinherited

Methods

noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
sleep(String name, Duration duration) Future<void>
Suspends the workflow for the given duration using a durable timer.
override
step<T>(String name, Future<T> action(), {Future<void> compensate(T result)?, RetryPolicy retry = RetryPolicy.none, String serialize(T value)?, T deserialize(String data)?}) Future<T>
Executes a named step with checkpoint/resume semantics.
override
toString() String
A string representation of this object.
inherited
waitSignal<T>(String signalName, {Duration? timeout}) Future<T?>
Suspends the workflow until an external signal is received.
override

Operators

operator ==(Object other) bool
The equality operator.
inherited