pub struct AgentRun<Event> { /* private fields */ }Expand description
A running agent turn exposed through a semantic event stream.
The application supplies the closure that performs provider requests and tool execution. This type owns only the background thread, event channel, and cooperative cancellation handle.
Implementations§
Source§impl<Event: Send + 'static> AgentRun<Event>
impl<Event: Send + 'static> AgentRun<Event>
Sourcepub fn spawn(
cancel: CancelToken,
run: impl FnOnce(Sender<Event>, CancelToken) + Send + 'static,
) -> Self
pub fn spawn( cancel: CancelToken, run: impl FnOnce(Sender<Event>, CancelToken) + Send + 'static, ) -> Self
Start a provider-neutral run on a background thread.
Sourcepub fn into_events(self) -> Receiver<Event>
pub fn into_events(self) -> Receiver<Event>
Consume the run and return its event receiver.
Sourcepub fn cancel(&self) -> &CancelToken
pub fn cancel(&self) -> &CancelToken
Return the cooperative cancellation handle for this run.
Trait Implementations§
Auto Trait Implementations§
impl<Event> !Sync for AgentRun<Event>
impl<Event> Freeze for AgentRun<Event>
impl<Event> RefUnwindSafe for AgentRun<Event>
impl<Event> Send for AgentRun<Event>where
Event: Send,
impl<Event> Unpin for AgentRun<Event>
impl<Event> UnsafeUnpin for AgentRun<Event>
impl<Event> UnwindSafe for AgentRun<Event>
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