Revert "init connect"

This reverts commit 276f225.

Author: yoshuawuyts

examples/client.rs

@@ -20,7 +20,11 @@ fn main() -> Result<(), async_h1::Exception> {
             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 res = client::connect(stream.clone(), req).await?;
+            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?;
             println!("{:?}", res);
         }
         Ok(())

src/client.rs

@@ -1,6 +1,6 @@
 //! Process HTTP connections on the client.
 
-use async_std::io::{self, BufReader, Read, Write};
+use async_std::io::{self, BufReader, Read};
 use async_std::prelude::*;
 use async_std::task::{Context, Poll};
 use futures_core::ready;
@@ -48,19 +48,8 @@ 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.
-async fn encode(req: Request) -> Result<Encoder, std::io::Error> {
+pub async fn encode(req: Request) -> Result<Encoder, std::io::Error> {
     let mut buf: Vec<u8> = vec![];
 
     let mut url = req.url().path().to_owned();
@@ -109,7 +98,7 @@ async fn encode(req: Request) -> Result<Encoder, std::io::Error> {
 }
 
 /// Decode an HTTP response on the client.
-async fn decode<R>(reader: R) -> Result<Response, Exception>
+pub async fn decode<R>(reader: R) -> Result<Response, Exception>
 where
     R: Read + Unpin + Send + Sync + 'static,
 {