Struct ProviderEventSink 

pub struct ProviderEventSink { /* private fields */ }

Sink supplied to providers that can produce incremental output.

Providers that only return a final response can keep implementing AgentProvider::invoke. Streaming providers call Self::output_delta while their invocation is running.

Implementations

impl ProviderEventSink

pub fn from_fn(emit: impl Fn(ProviderEvent) + Send + Sync + 'static) -> Self

Creates a sink that forwards every typed provider event to emit.

pub fn discard() -> Self

pub fn output_delta(&self, data: InvocationData)

pub fn activity(&self)

pub fn stage_started(&self, stage: ProviderStage, metadata: Value)

pub fn stage_completed( &self, stage: ProviderStage, elapsed_ms: u64, metadata: Value, )

pub fn stage_failed( &self, stage: ProviderStage, elapsed_ms: u64, error: impl Into<String>, metadata: Value, )

Trait Implementations

impl Clone for ProviderEventSink

fn clone(&self) -> ProviderEventSink

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ProviderEventSink

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

Formats the value using the given formatter.