Struct TimeoutLayer

pub struct TimeoutLayer<F> { /* private fields */ }

Applies a timeout to requests via the supplied inner service.

Implementations

impl TimeoutLayer<LayerErrorStatic<Elapsed>>

pub const fn new(timeout: Duration) -> TimeoutLayer<LayerErrorStatic<Elapsed>>

Create a timeout from a duration

impl<E> TimeoutLayer<LayerErrorStatic<E>>

pub const fn with_error( timeout: Duration, error: E, ) -> TimeoutLayer<LayerErrorStatic<E>>

where E: Clone + Send + Sync + 'static,

Creates a new TimeoutLayer with a custom error value.

impl<F> TimeoutLayer<LayerErrorFn<F>>

pub const fn with_error_fn<E>( timeout: Duration, error_fn: F, ) -> TimeoutLayer<LayerErrorFn<F>>

where F: Fn() -> E + Send + Sync + 'static, E: Send + 'static,

Creates a new TimeoutLayer with a custom error function.

Trait Implementations

impl<F> Clone for TimeoutLayer<F>

where F: Clone,

fn clone(&self) -> TimeoutLayer<F>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<P> Debug for TimeoutLayer<P>

where P: Debug,

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

Formats the value using the given formatter.

impl<S, F> Layer<S> for TimeoutLayer<F>

where F: MakeLayerError + Clone,

type Service = Timeout<S, F>

The service produced by the layer.

fn layer(&self, service: S) -> <TimeoutLayer<F> as Layer<S>>::Service

Wrap the given service with the middleware, returning a new service.

fn into_layer(self, service: S) -> <TimeoutLayer<F> as Layer<S>>::Service

Same as layer but consuming self after the service was created.