Struct Next 

pub struct Next { /* private fields */ }

Implementations

impl Next

pub async fn run(self, req: Request) -> Result<Response, Error>

Examples found in repository

examples/homepage.rs (line 17)

async fn request_id(mut req: Request, next: Next) -> Result<Response, Error> {
    let id = REQUEST_COUNTER.fetch_add(1, Ordering::Relaxed);
    req.ctx_mut().insert(RequestId(id));
    let mut resp = resolve(next.run(req).await);
    if let Ok(header) = format!("req-{id}").parse() {
        resp.headers_mut().insert("x-request-id", header);
    }
    Ok(resp)
}

async fn logger(req: Request, next: Next) -> Result<Response, Error> {
    let method = req.method().clone();
    let path = req.uri().path().to_owned();
    let id = req.ctx().get::<RequestId>().map(|r| r.0);
    let user = rustio_core::auth::identity(req.ctx()).map(|i| i.email.clone());
    let started = Instant::now();
    let result = next.run(req).await;
    let status = match &result {
        Ok(resp) => resp.status().as_u16(),
        Err(err) => err.status(),
    };
    let id_display = id.map(|i| format!("req-{i}")).unwrap_or_else(|| "-".into());
    let user_display = user.unwrap_or_else(|| "-".into());
    eprintln!(
        "[{:>3}] {:>4} {} id={} user={} ({:?})",
        status,
        method,
        path,
        id_display,
        user_display,
        started.elapsed()
    );
    result
}