Struct LoopFlow 

pub struct LoopFlow { /* private fields */ }

Loop a single body flow until the predicate returns Done.

Implementations

impl LoopFlow

pub fn new(name: impl Into<String>, body: Arc<dyn Flow>) -> Self

New loop. Default predicate returns Done immediately (single iter) so the caller is forced to call LoopFlow::until.

pub fn until<F>(self, predicate: F) -> Self

where F: Fn(&Value) -> LoopVerdict + Send + Sync + 'static,

Replace the termination predicate.

pub fn with_max_iters(self, n: u32) -> Self

Override the default cap (16). The cap bounds the number of body invocations — the body runs at most max_iters times.

pub fn with_body_agent<A>(name: impl Into<String>, agent: A) -> Self

where A: Agent + 'static,

Convenience constructor that wraps a concrete klieo_core::agent::Agent in crate::flow::AgentFlow and constructs a LoopFlow with the same defaults as LoopFlow::new (single-iteration predicate, max 16 iters).

Trait Implementations

impl Flow for LoopFlow

fn name(&self) -> &str

Stable flow name. Used in tracing spans.

fn run<'life0, 'async_trait>( &'life0 self, ctx: AgentContext, input: Value, ) -> Pin<Box<dyn Future<Output = Result<Value, FlowError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Execute the flow once.