rustio-core 0.1.1

Runtime core for RustIO: HTTP server, router, middleware, ORM, admin, and migrations.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

//! Around-style middleware.
//!
//! Each middleware is `async fn(Request, Next) -> Result<Response, Error>`
//! and decides when to call [`Next::run`]. Short-circuiting (returning a
//! response without calling next) is natural. [`Next`] is consumed by
//! `run`, so the type system prevents calling it twice.

use std::future::Future;
use std::pin::Pin;
use std::sync::Arc;

use crate::error::Error;
use crate::http::{Request, Response};

type BoxFuture<T> = Pin<Box<dyn Future<Output = T> + Send>>;

pub type MiddlewareFn =
    Arc<dyn Fn(Request, Next) -> BoxFuture<Result<Response, Error>> + Send + Sync>;

pub struct Next {
    inner: Box<dyn FnOnce(Request) -> BoxFuture<Result<Response, Error>> + Send>,
}

impl Next {
    pub(crate) fn new(
        inner: Box<dyn FnOnce(Request) -> BoxFuture<Result<Response, Error>> + Send>,
    ) -> Self {
        Self { inner }
    }

    pub async fn run(self, req: Request) -> Result<Response, Error> {
        (self.inner)(req).await
    }
}