Struct ConditionalScopeConfigurator 

pub struct ConditionalScopeConfigurator<'pipeline, TData: 'static + Send + Sync, SData: 'static + Send + Sync, Err: Error + From<OrkaError> + Send + Sync + 'static, P: PipelineProvider<TData, SData, Err> + 'static> { /* private fields */ }

Intermediate builder to configure a single conditional scope. TData: Main pipeline’s underlying context data type. SData: Scoped pipeline’s underlying context data type. Must be Send + Sync + 'static. Err: Error type of the main pipeline AND scoped pipelines. Must be From<OrkaError>. P: Concrete PipelineProvider<TData, SData, Err> (provides Pipeline<SData, Err>).

Implementations

impl<'pipeline, TData, SData, Err, P> ConditionalScopeConfigurator<'pipeline, TData, SData, Err, P>

where TData: 'static + Send + Sync, SData: 'static + Send + Sync, Err: Error + From<OrkaError> + Send + Sync + 'static, P: PipelineProvider<TData, SData, Err> + 'static,

pub fn on_condition( self, condition_fn: impl Fn(ContextData<TData>) -> bool + Send + Sync + 'static, ) -> ConditionalScopeBuilder<'pipeline, TData, Err>

Sets the condition for this scope. condition_fn takes ContextData<TData>. Returns ConditionalScopeBuilder<TData, Err>.