feat: Config support for wasm_client

Only supports `timeout`, unfortunately, and requires async-std...

Author: Fishrock123

Cargo.toml

@@ -26,7 +26,7 @@ docs = ["h1_client", "curl_client", "wasm_client", "hyper_client", "unstable-con
 h1_client = ["async-h1", "async-std", "deadpool", "futures"]
 native_client = ["curl_client", "wasm_client"]
 curl_client = ["isahc", "async-std"]
-wasm_client = ["js-sys", "web-sys", "wasm-bindgen", "wasm-bindgen-futures", "futures"]
+wasm_client = ["js-sys", "web-sys", "wasm-bindgen", "wasm-bindgen-futures", "futures", "async-std"]
 hyper_client = ["hyper", "hyper-tls", "http-types/hyperium_http", "futures-util", "tokio"]
 
 native-tls = ["async-native-tls"]

src/config.rs

@@ -11,10 +11,14 @@ pub struct Config {
     /// HTTP/1.1 `keep-alive` (connection pooling).
     ///
     /// Default: `true`.
+    ///
+    /// Note: Does nothing on `wasm_client`.
     pub http_keep_alive: bool,
     /// TCP `NO_DELAY`.
     ///
     /// Default: `false`.
+    ///
+    /// Note: Does nothing on `wasm_client`.
     pub tcp_no_delay: bool,
     /// Connection timeout duration.
     ///

src/wasm.rs

@@ -1,23 +1,34 @@
 //! http-client implementation for fetch
 
-use super::{http_types::Headers, Body, Error, HttpClient, Request, Response};
-
-use futures::prelude::*;
+#[cfg(feature = "unstable-config")]
+use std::convert::Infallible;
 
 use std::convert::TryFrom;
 use std::pin::Pin;
 use std::task::{Context, Poll};
 
+use futures::prelude::*;
+
+use crate::Config;
+
+use super::{http_types::Headers, Body, Error, HttpClient, Request, Response};
+
 /// WebAssembly HTTP Client.
 #[derive(Debug)]
 pub struct WasmClient {
-    _priv: (),
+    config: Config,
 }
 
 impl WasmClient {
     /// Create a new instance.
     pub fn new() -> Self {
-        Self { _priv: () }
+        Self { config: Config::default() }
+    }
+}
+
+impl Default for WasmClient {
+    fn default() -> Self {
+        Self::new()
     }
 }
 
@@ -30,9 +41,19 @@ impl HttpClient for WasmClient {
         'a: 'async_trait,
         Self: 'async_trait,
     {
+        let config = self.config.clone();
+
         InnerFuture::new(async move {
             let req: fetch::Request = fetch::Request::new(req).await?;
-            let mut res = req.send().await?;
+            let conn = req.send();
+            #[cfg(feature = "unstable-config")]
+            let mut res = if let Some(timeout) = config.timeout {
+                async_std::future::timeout(timeout, conn).await??
+            } else {
+                conn.await?
+            };
+            #[cfg(not(feature = "unstable-config"))]
+            let mut res = conn.await?;
 
             let body = res.body_bytes();
             let mut response =
@@ -46,6 +67,36 @@ impl HttpClient for WasmClient {
             Ok(response)
         })
     }
+
+    #[cfg_attr(feature = "docs", doc(cfg(feature = "unstable-config")))]
+    #[cfg(feature = "unstable-config")]
+    /// Override the existing configuration with new configuration.
+    ///
+    /// Config options may not impact existing connections.
+    fn set_config(&mut self, config: Config) -> http_types::Result<()> {
+        self.config = config;
+
+        Ok(())
+    }
+
+    #[cfg_attr(feature = "docs", doc(cfg(feature = "unstable-config")))]
+    #[cfg(feature = "unstable-config")]
+    /// Get the current configuration.
+    fn config(&self) -> &Config {
+        &self.config
+    }
+}
+
+#[cfg_attr(feature = "docs", doc(cfg(feature = "unstable-config")))]
+#[cfg(feature = "unstable-config")]
+impl TryFrom<Config> for WasmClient {
+    type Error = Infallible;
+
+    fn try_from(config: Config) -> Result<Self, Self::Error> {
+        Ok(Self {
+            config,
+        })
+    }
 }
 
 struct InnerFuture {