Struct Timed 

pub struct Timed<R, I, O>
where
    R: Runnable<I, O> + 'static,
    I: Send + 'static,
    O: Send + 'static,
{ /* private fields */ }

Runnable<I, O> adapter that aborts the inner with Error::DeadlineExceeded if it does not complete within timeout.

Implementations

impl<R, I, O> Timed<R, I, O>

where R: Runnable<I, O> + 'static, I: Send + 'static, O: Send + 'static,

pub fn new(inner: R, timeout: Duration) -> Self

Build with the inner runnable and a wall-clock timeout.

Trait Implementations

impl<R, I, O> Debug for Timed<R, I, O>

where R: Runnable<I, O> + 'static, I: Send + 'static, O: Send + 'static,

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

Formats the value using the given formatter.

impl<R, I, O> Runnable<I, O> for Timed<R, I, O>

where R: Runnable<I, O> + 'static, I: Send + 'static, O: Send + 'static,

fn invoke<'life0, 'life1, 'async_trait>( &'life0 self, input: I, ctx: &'life1 ExecutionContext, ) -> Pin<Box<dyn Future<Output = Result<O>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Single-shot invocation.

fn batch<'life0, 'life1, 'async_trait>( &'life0 self, inputs: Vec<I>, ctx: &'life1 ExecutionContext, ) -> Pin<Box<dyn Future<Output = Result<Vec<O>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Batch invocation. The default runs invoke sequentially over the input vector. Implementors that can parallelize (e.g. independent provider calls) override this.

fn stream<'life0, 'life1, 'async_trait>( &'life0 self, input: I, mode: StreamMode, ctx: &'life1 ExecutionContext, ) -> Pin<Box<dyn Future<Output = Result<BoxStream<'_, Result<StreamChunk<O>>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Streaming invocation, shaped by mode (see StreamMode).

fn name(&self) -> Cow<'_, str>

Human-readable identifier used by tracing and debug output. Default is the Rust type name — implementors may override with a domain label (e.g. "anthropic-messages", "json-parser").