Eliminating locking and improve safety with Pagers, Pollers

Resolves #3294

Author: heaths

Cargo.lock

@@ -36,6 +36,26 @@ pub mod tracing {
 #[cfg(feature = "xml")]
 pub use typespec_client_core::xml;
 
+#[cfg(not(target_arch = "wasm32"))]
+mod conditional_send {
+    /// Conditionally implements [`Send`] based on the `target_arch`.
+    ///
+    /// This implementation requires `Send`.
+    pub trait ConditionalSend: Send {}
+
+    impl<T> ConditionalSend for T where T: Send {}
+}
+
+#[cfg(target_arch = "wasm32")]
+mod conditional_send {
+    /// Conditionally implements [`Send`] based on the `target_arch`.
+    ///
+    /// This implementation does not require `Send`.
+    pub trait ConditionalSend {}
+
+    impl<T> ConditionalSend for T {}
+}
+
 mod private {
     pub trait Sealed {}
 }

sdk/core/azure_core/src/http/pager.rs

@@ -35,6 +35,7 @@ include-file.workspace = true
 openssl.workspace = true
 rand.workspace = true
 tokio.workspace = true
+tracing.workspace = true
 
 [build-dependencies]
 rustc_version.workspace = true

sdk/core/azure_core/src/lib.rs

@@ -219,7 +219,7 @@ async fn list_certificates(ctx: TestContext) -> Result<()> {
         .await?;
 
     // List certificates.
-    let mut pager = client.list_certificate_properties(None)?.into_stream();
+    let mut pager = client.list_certificate_properties(None)?;
     while let Some(certificate) = pager.try_next().await? {
         // Get the certificate name from the ID.
         let name = certificate.resource_id()?.name;
@@ -268,11 +268,11 @@ async fn purge_certificate(ctx: TestContext) -> Result<()> {
     loop {
         match client.purge_deleted_certificate(NAME.as_ref(), None).await {
             Ok(_) => {
-                println!("{NAME} has been purged");
+                tracing::debug!("{NAME} has been purged");
                 break;
             }
             Err(err) if matches!(err.http_status(), Some(StatusCode::Conflict)) => {
-                println!(
+                tracing::debug!(
                     "Retrying in {} seconds",
                     retry.duration().unwrap_or_default().as_secs_f32()
                 );

sdk/keyvault/azure_security_keyvault_certificates/Cargo.toml

@@ -36,6 +36,7 @@ rand_chacha.workspace = true
 reqwest.workspace = true
 sha2.workspace = true
 tokio.workspace = true
+tracing.workspace = true
 
 [build-dependencies]
 rustc_version.workspace = true

sdk/keyvault/azure_security_keyvault_certificates/src/generated/clients/certificate_client.rs

@@ -196,11 +196,11 @@ async fn purge_key(ctx: TestContext) -> Result<()> {
     loop {
         match client.purge_deleted_key(name.as_ref(), None).await {
             Ok(_) => {
-                println!("{name} has been purged");
+                tracing::debug!("{name} has been purged");
                 break;
             }
             Err(err) if matches!(err.http_status(), Some(StatusCode::Conflict)) => {
-                println!(
+                tracing::debug!(
                     "Retrying in {} seconds",
                     retry.duration().unwrap_or_default().as_secs_f32()
                 );

sdk/keyvault/azure_security_keyvault_certificates/src/generated/models/method_options.rs

@@ -34,6 +34,7 @@ azure_security_keyvault_test = { path = "../azure_security_keyvault_test" }
 include-file.workspace = true
 rand.workspace = true
 tokio.workspace = true
+tracing.workspace = true
 
 [build-dependencies]
 rustc_version.workspace = true