async_h1/client/
mod.rs

1//! Process HTTP connections on the client.
2
3use futures_lite::io::{self, AsyncRead as Read, AsyncWrite as Write};
4use http_types::{Request, Response};
5
6mod decode;
7mod encode;
8
9pub use decode::decode;
10pub use encode::Encoder;
11
12/// Opens an HTTP/1.1 connection to a remote host.
13pub async fn connect<RW>(mut stream: RW, req: Request) -> http_types::Result<Response>
14where
15    RW: Read + Write + Send + Sync + Unpin + 'static,
16{
17    let mut req = Encoder::new(req);
18    log::trace!("> {:?}", &req);
19
20    io::copy(&mut req, &mut stream).await?;
21
22    let res = decode(stream).await?;
23    log::trace!("< {:?}", &res);
24
25    Ok(res)
26}
async_h1/client/mod.rs

async_h1/client/
mod.rs
