async-http-client-lite 0.1.0

Asynchronous http client.
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
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62

use std::io;

use futures_io::{AsyncRead, AsyncWrite};
use http::{Request, Response, Version};

//
#[cfg(feature = "h1__async_http1_lite")]
use async_http1_lite::Http1ClientStream as AsyncHttp1LiteHttp1ClientStream;

//
use crate::client::Client;

//
//
//
pub enum ClientBackendKind {
    #[cfg(feature = "h1__async_http1_lite")]
    H1AsyncHttp1Lite,
}

impl<S> Client<S>
where
    S: AsyncRead + AsyncWrite + Unpin + Send + 'static,
{
    pub async fn response(
        &mut self,
        request: Request<Vec<u8>>,
        backend_kind: ClientBackendKind,
    ) -> io::Result<(Response<Vec<u8>>, Option<Vec<u8>>)> {
        if request.version() <= Version::HTTP_11 {
            match backend_kind {
                #[cfg(feature = "h1__async_http1_lite")]
                ClientBackendKind::H1AsyncHttp1Lite => {
                    let mut stream = AsyncHttp1LiteHttp1ClientStream::new(self.get_mut());
                    stream.write_request(request).await?;

                    let (response, reason_phrase) = stream.read_response().await?;

                    Ok((response, reason_phrase))
                }
            }
        } else if request.version() <= Version::HTTP_2 {
            // TODO, `curl -x https://proxy.lvh.me:9118 https://httpbin.org/ip -v --proxy-insecure` is very slow, maybe warning it is better.
            return Err(io::Error::new(io::ErrorKind::Other, "unimplemented now"));
        } else {
            return Err(io::Error::new(io::ErrorKind::Other, "unimplemented now"));
        }
    }
}

//
//
//
impl<S> Client<S>
where
    S: AsyncRead + AsyncWrite + Unpin + Send + 'static,
{
    #[cfg(feature = "h1__async_http1_lite")]
    pub fn into_async_http1_lite(self) -> io::Result<AsyncHttp1LiteHttp1ClientStream<S>> {
        Ok(AsyncHttp1LiteHttp1ClientStream::new(self.into_inner()))
    }
}