Struct StartedChildWorkflow 

pub struct StartedChildWorkflow<WD: WorkflowDefinition> {
    pub run_id: String,
    /* private fields */
}

Child workflow in started state.

Fields

run_id: String

Run ID of the child workflow

Implementations

impl<WD: WorkflowDefinition> StartedChildWorkflow<WD>

where WD::Output: TemporalDeserializable + 'static,

pub fn result( self, ) -> impl CancellableFutureWithReason<Output = Result<WD::Output, ChildWorkflowExecutionError>>

Consumes self and returns a future that deserializes the child workflow result into WD::Output.

pub fn cancel(&self, reason: String)

Cancel the child workflow

pub fn signal<S: SignalDefinition<Workflow = WD> + 'static>( &self, signal: S, input: S::Input, options: SignalWorkflowOptions, ) -> impl CancellableFuture<Output = Result<(), WorkflowSignalError>> + 'static

Send a typed signal to the child workflow.

By default, the signal inherits workflow cancellation.

Trait Implementations

impl<WD: WorkflowDefinition> Debug for StartedChildWorkflow<WD>

where PhantomData<WD>: Debug,

fn fmt(&self, __derive_more_f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.