Struct AgentStream 

pub struct AgentStream<S, Output> { /* private fields */ }

Streaming agent execution.

This struct wraps the streaming execution of an agent run, emitting events as the model generates responses.

Implementations

impl<S, Output> AgentStream<S, Output>

where S: Stream<Item = StreamResult<ResponseDelta>>, Output: DeserializeOwned,

pub fn new(inner: S, run_id: impl Into<String>) -> Self

Create a new agent stream.

pub fn with_config(self, config: StreamConfig) -> Self

Set the stream configuration.

pub fn run_id(&self) -> &str

Get the run ID.

pub fn step(&self) -> u32

Get the current step.

pub fn state(&self) -> StreamState

Get the current state.

pub fn partial_response(&self) -> &PartialResponse

Get the current partial response.

pub fn response_snapshot(&self) -> ModelResponse

Get the accumulated response as a snapshot.

pub fn text_content(&self) -> String

Get the accumulated text content.

pub fn usage(&self) -> &RequestUsage

Get accumulated usage.

pub fn is_complete(&self) -> bool

Check if the stream is complete.

Trait Implementations

impl<S, Output> Stream for AgentStream<S, Output>

where S: Stream<Item = StreamResult<ResponseDelta>> + Unpin, Output: DeserializeOwned + Clone,

type Item = AgentStreamEvent<Output>

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.

impl<'__pin, S, Output> Unpin for AgentStream<S, Output>

where PinnedFieldsOf<__Origin<'__pin, S, Output>>: Unpin,