Revert "Revert "init connect""

This reverts commit 8339bd6.

Author: yoshuawuyts

examples/client.rs

@@ -20,11 +20,7 @@ fn main() -> Result<(), Error> {
             println!("making request {}/2", i + 1);
             let url = Url::parse(&format!("http://{}/foo", peer_addr)).unwrap();
             let req = Request::new(Method::Get, dbg!(url));
-            let mut req = client::encode(req).await?;
-            io::copy(&mut req, &mut stream.clone()).await?;
-
-            // read the response
-            let res = client::decode(stream.clone()).await?;
+            let res = client::connect(stream.clone(), req).await?;
             println!("{:?}", res);
         }
         Ok(())

src/client.rs

@@ -1,6 +1,6 @@
 //! Process HTTP connections on the client.
 
-use async_std::io::{self, BufReader, Read};
+use async_std::io::{self, BufReader, Read, Write};
 use async_std::prelude::*;
 use async_std::task::{Context, Poll};
 use futures_core::ready;
@@ -48,6 +48,17 @@ impl Encoder {
     }
 }
 
+/// Send an HTTP request over a stream.
+pub async fn connect<RW>(stream: RW, req: Request) -> Result<Response, std::io::Error>
+where
+    RW: Read + Write + Clone + Send + Sync + Unpin + 'static,
+{
+    let mut req = encode(req).await?;
+    io::copy(&mut req, &mut stream.clone()).await?;
+    let res = decode(stream.clone()).await.unwrap(); // todo: convert to http_types::Error
+    Ok(res)
+}
+
 /// Encode an HTTP request on the client.
 pub async fn encode(req: Request) -> Result<Encoder, Error> {
     let mut buf: Vec<u8> = vec![];