Struct TimeoutLayer 

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

Available on crate feature server only.

Layer for setting timeout to the request

See TimeoutLayer::new for more details.

Implementations

impl<H> TimeoutLayer<H>

pub fn new(duration: Duration, handler: H) -> Self

Create a new TimeoutLayer with given Duration and handler.

The handler should be a sync function with &ServerContext as parameter, and return anything that implement IntoResponse.

Examples

use std::time::Duration;

use http::status::StatusCode;
use volo_http::{
    context::ServerContext,
    server::{
        layer::TimeoutLayer,
        route::{Router, get},
    },
};

async fn index() -> &'static str {
    "Hello, World"
}

fn timeout_handler(_: &ServerContext) -> StatusCode {
    StatusCode::REQUEST_TIMEOUT
}

let router: Router = Router::new()
    .route("/", get(index))
    .layer(TimeoutLayer::new(Duration::from_secs(1), timeout_handler));

Trait Implementations

impl<H: Clone> Clone for TimeoutLayer<H>

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

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

where S: Send + Sync + 'static,

type Service = Timeout<S, H>

The wrapped service

fn layer(self, inner: S) -> Self::Service

Wrap the given service with the middleware, returning a new service that has been decorated with the middleware. Consumes self.