boluo-core 0.6.0

boluo的核心类型和特征
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
35
36
37
38
39
40
41
42
43

use std::any::Any;

use crate::BoxError;
use crate::request::Request;
use crate::response::{IntoResponse, Response};
use crate::service::{ArcService, Service, ServiceExt};

/// Private API
#[doc(hidden)]
pub fn __try_downcast<Src: 'static, Dst: 'static>(src: Src) -> Result<Dst, Src> {
    let mut src = Some(src);
    match <dyn Any>::downcast_mut::<Option<Dst>>(&mut src) {
        Some(dst) => Ok(dst.take().unwrap()),
        _ => Err(src.unwrap()),
    }
}

/// Private API
#[doc(hidden)]
pub fn __into_arc_service<S>(service: S) -> ArcService<Request, Response, BoxError>
where
    S: Service<Request> + 'static,
    S::Response: IntoResponse,
    S::Error: Into<BoxError>,
{
    __try_downcast(service).unwrap_or_else(|service| {
        let service = service.map_result(|result| {
            result
                .map_err(Into::into)
                .and_then(|r| r.into_response().map_err(Into::into))
        });
        service.boxed_arc()
    })
}

/// 断言 `S` 是一个 [`Service`]。
#[inline]
pub(crate) fn assert_service<S, R>(service: S) -> S
where
    S: Service<R>,
{
    service
}