Struct Timeout

pub struct Timeout<S, F> { /* private fields */ }

Applies a timeout to requests.

Implementations

impl<S, F> Timeout<S, F>

pub fn get_ref(&self) -> &S

Gets a reference to the underlying service.

pub fn into_inner(self) -> S

Consumes self, returning the underlying service.

impl<S> Timeout<S, LayerErrorStatic<Elapsed>>

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

Creates a new Timeout

impl<S, E> Timeout<S, LayerErrorStatic<E>>

pub fn with_error(inner: S, timeout: Duration, error: E) -> Self

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

Creates a new Timeout with a custom error value.

impl<S, F> Timeout<S, LayerErrorFn<F>>

pub fn with_error_fn<E>(inner: S, timeout: Duration, error_fn: F) -> Self

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

Creates a new Timeout with a custom error function.

Trait Implementations

impl<S, F> Clone for Timeout<S, F>

where S: Clone, F: Clone,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S: Debug, F: Debug> Debug for Timeout<S, F>

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

Formats the value using the given formatter.

impl<T, F, S, Request, E> Service<S, Request> for Timeout<T, F>

where Request: Send + 'static, S: Clone + Send + Sync + 'static, F: MakeLayerError<Error = E>, E: Into<T::Error> + Send + 'static, T: Service<S, Request>,

type Response = <T as Service<S, Request>>::Response

The type of response returned by the service.

type Error = <T as Service<S, Request>>::Error

The type of error returned by the service.

async fn serve( &self, ctx: Context<S>, request: Request, ) -> Result<Self::Response, Self::Error>

Serve a response or error for the given request, using the given context.

fn boxed(self) -> BoxService<S, Request, Self::Response, Self::Error>

Box this service to allow for dynamic dispatch.