pub struct LoopTextAgent { /* private fields */ }Expand description
Runs a text agent repeatedly until max iterations or a state predicate.
Implementations§
Source§impl LoopTextAgent
impl LoopTextAgent
Sourcepub fn new(name: impl Into<String>, body: Arc<dyn TextAgent>, max: u32) -> Self
pub fn new(name: impl Into<String>, body: Arc<dyn TextAgent>, max: u32) -> Self
Create a new loop agent that repeats up to max iterations.
Sourcepub fn until(
self,
pred: impl Fn(&State) -> bool + Send + Sync + 'static,
) -> Self
pub fn until( self, pred: impl Fn(&State) -> bool + Send + Sync + 'static, ) -> Self
Add a predicate — loop breaks when predicate returns true.
Sourcepub fn with_middleware_chain(self, chain: MiddlewareChain) -> Self
pub fn with_middleware_chain(self, chain: MiddlewareChain) -> Self
Attach a middleware chain. AgentEvent::LoopIteration is emitted through
it on every iteration, so on_event observers (e.g. M::on_loop) fire.
Trait Implementations§
Source§impl TextAgent for LoopTextAgent
impl TextAgent for LoopTextAgent
Source§fn run<'life0, 'life1, 'async_trait>(
&'life0 self,
state: &'life1 State,
) -> Pin<Box<dyn Future<Output = Result<String, AgentError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn run<'life0, 'life1, 'async_trait>(
&'life0 self,
state: &'life1 State,
) -> Pin<Box<dyn Future<Output = Result<String, AgentError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Execute this agent. Reads/writes
state. Returns the final text output.Auto Trait Implementations§
impl Freeze for LoopTextAgent
impl !RefUnwindSafe for LoopTextAgent
impl Send for LoopTextAgent
impl Sync for LoopTextAgent
impl Unpin for LoopTextAgent
impl !UnwindSafe for LoopTextAgent
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more