Skip to main content

AgentRun

Struct AgentRun 

Source
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>

Source

pub fn spawn( cancel: CancelToken, run: impl FnOnce(Sender<Event>, CancelToken) + Send + 'static, ) -> Self

Start a provider-neutral run on a background thread.

Source

pub fn into_events(self) -> Receiver<Event>

Consume the run and return its event receiver.

Source

pub fn cancel(&self) -> &CancelToken

Return the cooperative cancellation handle for this run.

Trait Implementations§

Source§

impl<Event: Debug> Debug for AgentRun<Event>

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more

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> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.