adds pub async fn ready to each of conn::{http1,http2}::SendRequest

Author: Michael-J-Ward

src/client/conn/http1.rs

@@ -137,6 +137,13 @@ impl<B> SendRequest<B> {
         self.dispatch.poll_ready(cx)
     }
 
+    /// Waits until the dispatcher is ready
+    ///
+    /// If the associated connection is closed, this returns an Error.
+    pub async fn ready(&mut self) -> crate::Result<()> {
+        futures_util::future::poll_fn(|cx| self.poll_ready(cx)).await
+    }
+
     /*
     pub(super) async fn when_ready(self) -> crate::Result<Self> {
         let mut me = Some(self);

src/client/conn/http2.rs

@@ -74,6 +74,13 @@ impl<B> SendRequest<B> {
         }
     }
 
+    /// Waits until the dispatcher is ready
+    ///
+    /// If the associated connection is closed, this returns an Error.
+    pub async fn ready(&mut self) -> crate::Result<()> {
+        futures_util::future::poll_fn(|cx| self.poll_ready(cx)).await
+    }
+
     /*
     pub(super) async fn when_ready(self) -> crate::Result<Self> {
         let mut me = Some(self);

src/client/conn/mod.rs

@@ -41,8 +41,7 @@
 //!
 //!     // To send via the same connection again, it may not work as it may not be ready,
 //!     // so we have to wait until the request_sender becomes ready.
-//!     // TODO:(mike) how to handle readiness
-//!     // request_sender.ready().await?;
+//!     request_sender.ready().await?;
 //!     let request = Request::builder()
 //!         .header("Host", "example.com")
 //!         .method("GET")