Struct SubFlow 

pub struct SubFlow;

Creates durable SubFlow Conditions and reads their Execute results.

Construction encodes input and returns a Condition; Dex starts or attaches to the child when the Worker submits that wait. The target Flow must be in the Worker’s Registry. The parent waits durably without holding a handler thread. Inspect FlowResult for child failure; a child’s abnormal terminal status is a result rather than a local value-mapping error. Result indexes are zero-based within the SubFlow Conditions, not all Condition kinds.

use dex_sdk::{Flow, SdkResult, SubFlow, SubFlowOptions, Wait};
use std::time::Duration;
fn wait_for_child<F: Flow>(flow: &F, input: F::StartInput) -> SdkResult<Wait> {
    let child = SubFlow::run_with_options(flow, input,
        SubFlowOptions::new().timeout(Duration::from_secs(60)))?;
    Ok(Wait::until(child))
}

Implementations

impl SubFlow

pub fn run<SomeFlow: Flow>( flow: &SomeFlow, input: SomeFlow::StartInput, ) -> SdkResult<Condition>

Creates a SubFlow Condition with default options.

Errors

Returns a value-mapping error when input cannot be encoded.

pub fn run_with_options<SomeFlow: Flow>( flow: &SomeFlow, input: SomeFlow::StartInput, options: SubFlowOptions, ) -> SdkResult<Condition>

Creates a SubFlow Condition with explicit options.

Errors

Returns a value-mapping error when input cannot be encoded. Worker mapping later validates the exact registered Rust Flow type, starting Step, Attributes, and option durations.

pub fn condition_result(context: &Context) -> HandlerResult<FlowResult>

Returns the first SubFlow result during Step execute.

Errors

Returns crate::HandlerError outside Execute or when the selected SubFlow result is unavailable or malformed. See SubFlow for constructing the matching wait.

pub fn condition_result_at( context: &Context, index: usize, ) -> HandlerResult<FlowResult>

Returns one stable-indexed SubFlow result during Step execute.

Errors

Returns crate::HandlerError outside Execute or when the selected SubFlow result is unavailable or malformed. See SubFlow for constructing the matching wait.

pub fn flow_id(context: &Context) -> HandlerResult<String>

Returns the generated Flow ID for the first SubFlow Condition during Step execute.

Errors

Returns crate::HandlerError outside Execute or when the selected SubFlow result is unavailable or malformed. See SubFlow for constructing the matching wait.

pub fn flow_id_at(context: &Context, index: usize) -> HandlerResult<String>

Returns the generated Flow ID for one stable-indexed SubFlow Condition during execute.

Errors

Returns crate::HandlerError outside Execute or when the selected SubFlow result is unavailable or malformed. See SubFlow for constructing the matching wait.