Struct AssistantMessageEventStream 

pub struct AssistantMessageEventStream { /* private fields */ }

A stream of assistant message events.

This wraps an async channel and provides:

• Async iteration over events via Stream trait
• A result() method to await the final AssistantMessage

The stream is created by provider implementations and events are pushed via the sender handle returned from AssistantMessageEventStream::new().

Implementations

impl AssistantMessageEventStream

pub fn new() -> (Self, EventStreamSender)

Create a new event stream and sender pair.

The sender is used by provider implementations to push events. The stream is returned to the caller for iteration.

pub async fn result(self) -> Result<AssistantMessage>

Await the final result of the stream.

This consumes the result receiver, so it can only be called once. Returns the final AssistantMessage when the stream completes.

Trait Implementations

impl Default for AssistantMessageEventStream

fn default() -> Self

Returns the “default value” for a type.

impl Stream for AssistantMessageEventStream

type Item = AssistantMessageEvent

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.