teo_runtime/middleware/
next.rs

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
use std::future::Future;
use futures_util::future::BoxFuture;
use crate::request::Request;
use crate::response::Response;

pub trait Next: Send + Sync {
    fn call(&self, request: Request) -> BoxFuture<'static, teo_result::Result<Response>>;
}

impl<F, Fut> Next for F where
    F: Fn(Request) -> Fut + Sync + Send,
    Fut: Future<Output = teo_result::Result<Response>> + Send + 'static {
    fn call(&self, ctx: Request) -> BoxFuture<'static, teo_result::Result<Response>> {
        Box::pin(self(ctx))
    }
}