rama-core 0.2.0-alpha.11

rama service core code, used by rama and service authors
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

use crate::{Context, Service};

impl<I, StateIn, StateOut, RequestIn, RequestOut> Service<StateIn, RequestIn> for Option<I>
where
    I: Service<StateIn, RequestIn, Response = (Context<StateOut>, RequestOut)>,
    StateIn: Into<StateOut> + Clone + Send + Sync + 'static,
    StateOut: Clone + Send + Sync + 'static,
    RequestIn: Into<RequestOut> + Send + 'static,
    RequestOut: Send + 'static,
{
    type Error = I::Error;
    type Response = I::Response;

    async fn serve(
        &self,
        ctx: Context<StateIn>,
        req: RequestIn,
    ) -> Result<Self::Response, Self::Error> {
        match self {
            Some(inspector) => inspector.serve(ctx, req).await,
            None => Ok((ctx.map_state(Into::into), req.into())),
        }
    }
}