typespec_client_core: New web_runtime to support wasm32-unknown-unknown

Cargo.toml

@@ -83,6 +83,7 @@ fe2o3-amqp-types = { version = "0.14" }
 flate2 = "1.1.0"
 futures = "0.3"
 getrandom = { version = "0.3" }
+gloo-timers = { version = "0.3" }
 hmac = { version = "0.12" }
 litemap = "0.7.4"
 log = "0.4"

sdk/typespec/typespec_client_core/Cargo.toml

@@ -36,6 +36,7 @@ tokio = { workspace = true, features = ["macros", "rt-multi-thread", "time"] }
 [target.'cfg(target_family = "wasm")'.dependencies]
 getrandom.workspace = true
 tokio = { workspace = true, features = ["macros", "rt", "time"] }
+gloo-timers = { workspace = true, features = ["futures"] }
 
 [dev-dependencies]
 tokio.workspace = true

sdk/typespec/typespec_client_core/src/http/policies/retry/mod.rs

@@ -76,7 +76,8 @@ pub fn get_retry_after(headers: &Headers, now: DateTimeFn) -> Option<Duration> {
 ///
 /// `wait` can be implemented in more complex cases where a simple test of time
 /// is not enough.
-#[async_trait]
+#[cfg_attr(target_arch = "wasm32", async_trait(?Send))]
+#[cfg_attr(not(target_arch = "wasm32"), async_trait)]
 pub trait RetryPolicy: std::fmt::Debug + Send + Sync {
     /// Determine if no more retries should be performed.
     ///

sdk/typespec/typespec_client_core/src/sleep.rs

@@ -3,8 +3,12 @@
 
 //! Sleep functions.
 
-use crate::{async_runtime::get_async_runtime, time::Duration};
+use crate::time::Duration;
 
+#[cfg(not(target_family = "wasm"))]
+use crate::async_runtime::get_async_runtime;
+
+#[cfg(not(target_family = "wasm"))]
 /// Sleeps for the specified duration using the configured async runtime.
 ///
 /// # Arguments
@@ -27,3 +31,13 @@ use crate::{async_runtime::get_async_runtime, time::Duration};
 pub async fn sleep(duration: Duration) {
     get_async_runtime().sleep(duration).await
 }
+
+#[cfg(target_family = "wasm")]
+pub async fn sleep(duration: Duration) {
+    if let Ok(d) = duration.try_into() {
+        gloo_timers::future::sleep(d).await;
+    } else {
+        // This means the duration is negative, don't sleep at all.
+        return;
+    }
+}