Struct AgentStreamCall 

pub struct AgentStreamCall<O> {
    pub call: AgentCall<O>,
    /* private fields */
}

Parameters of one streaming agent call.

Fields

call: AgentCall<O>

The shared call parameters.

Implementations

impl<O> AgentStreamCall<O>

pub fn new(call: AgentCall<O>) -> Self

Wraps a call.

pub fn transform(self, transform: impl StreamTransform + 'static) -> Self

Adds a stream transform (applied in order).

pub fn include_raw_chunks(self) -> Self

Forwards raw provider chunks.

pub fn stream_retries(self, retries: u32) -> Self

Enables automatic retries of failed model streams.

pub fn on_error(self, f: impl OnErrorFn) -> Self

Sets the stream error callback.

pub fn on_chunk(self, f: impl HookFn<StreamEvent>) -> Self

Adds a chunk hook.

pub fn on_abort(self, f: impl HookFn<AbortEvent>) -> Self

Adds an abort hook.

Trait Implementations

impl<O: Debug> Debug for AgentStreamCall<O>

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

Formats the value using the given formatter.

impl<O> From<AgentCall<O>> for AgentStreamCall<O>

fn from(call: AgentCall<O>) -> Self

Converts to this type from the input type.