diff options
Diffstat (limited to 'lampada/src/connection/write.rs')
| -rw-r--r-- | lampada/src/connection/write.rs | 11 |
1 files changed, 2 insertions, 9 deletions
diff --git a/lampada/src/connection/write.rs b/lampada/src/connection/write.rs index 4c6ed24..b982eea 100644 --- a/lampada/src/connection/write.rs +++ b/lampada/src/connection/write.rs @@ -8,6 +8,8 @@ use tokio::{ sync::{mpsc, oneshot}, task::JoinHandle, }; +#[cfg(target_arch = "wasm32")] +use tokio_with_wasm::alias as tokio; use crate::error::WriteError; @@ -218,9 +220,6 @@ impl WriteControlHandle { let (stanza_sender, stanza_receiver) = mpsc::channel(20); let actor = Write::new(stream, stanza_receiver, control_receiver, on_crash); - #[cfg(target_arch = "wasm32")] - wasm_bindgen_futures::spawn_local(async move { actor.run().await }); - #[cfg(not(target_arch = "wasm32"))] tokio::spawn(async move { actor.run().await }); ( @@ -242,9 +241,6 @@ impl WriteControlHandle { let (control_sender, control_receiver) = mpsc::channel(20); let actor = Write::new(stream, stanza_receiver, control_receiver, on_crash); - #[cfg(target_arch = "wasm32")] - wasm_bindgen_futures::spawn_local(async move { actor.run_reconnected(retry_msg).await }); - #[cfg(not(target_arch = "wasm32"))] tokio::spawn(async move { actor.run_reconnected(retry_msg).await }); Self { @@ -261,9 +257,6 @@ impl WriteControlHandle { let actor = Write::new(stream, stanza_receiver, control_receiver, on_crash); - #[cfg(target_arch = "wasm32")] - wasm_bindgen_futures::spawn_local(async move { actor.run().await }); - #[cfg(not(target_arch = "wasm32"))] tokio::spawn(async move { actor.run().await }); Self { |