pi_http 0.6.1

pi_http
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

use std::io::Error;

use futures::future::{FutureExt, LocalBoxFuture};

use tcp::Socket;

use crate::{request::HttpRequest, response::HttpResponse};

///
/// Http服务工厂
///
pub trait ServiceFactory<S: Socket>: Clone + Send + Sync + 'static {
    type Service: HttpService<S>;

    //构建Http服务
    fn new_service(&self) -> Self::Service;
}

///
/// Http服务
///
pub trait HttpService<S: Socket>: Send + Sync + 'static {
    type Error:     Into<Error> + Send;

    //调用服务
    fn call(&mut self, req: HttpRequest<S>)
        -> LocalBoxFuture<'static, Result<HttpResponse, Self::Error>>;
}

///
/// 调用阻塞函数，返回Future
///
pub fn block_call<S, F, Error>(fun: F,
                               req: HttpRequest<S>)
    -> LocalBoxFuture<'static, Result<HttpResponse, Error>>
    where S: Socket,
          F: FnOnce(HttpRequest<S>) -> Result<HttpResponse, Error> + Send + 'static {
    let future = async move {
        fun(req)
    };
    future.boxed_local()
}