Struct LoopOp 

pub struct LoopOp<T> { /* private fields */ }

Loop operation that executes a batch of operations repeatedly until a limit is reached

Implementations

impl<T> LoopOp<T>

where T: Send + 'static,

pub fn new(counter_var: String, limit: usize, ops: Vec<Arc<dyn Op<T>>>) -> Self

Create a new loop operation

Arguments

• counter_var - Name of the counter variable to store in context
• limit - Maximum number of iterations to perform
• ops - Vector of operations to execute in each iteration

pub fn add_op(self, op: Arc<dyn Op<T>>) -> Self

Add an operation to the loop

pub fn with_continue_on_error(self, continue_on_error: bool) -> Self

Set whether to continue on error

Trait Implementations

impl<T> Op<Vec<T>> for LoopOp<T>

where T: Send + 'static,

fn perform<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, dry: &'life1 mut DryContext, wet: &'life2 mut WetContext, ) -> Pin<Box<dyn Future<Output = OpResult<Vec<T>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn metadata(&self) -> OpMetadata

fn rollback<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _dry: &'life1 mut DryContext, _wet: &'life2 mut WetContext, ) -> Pin<Box<dyn Future<Output = OpResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Optional rollback method for ops that need custom cleanup logic. Default implementation is a no-op for backward compatibility. Called automatically by batch operations when a later op fails.