From b9d75f38743113c054be3d97af36bdd2a7dd0d69 Mon Sep 17 00:00:00 2001 From: cel 🌸 Date: Thu, 17 Apr 2025 11:03:51 +0100 Subject: feat(filamento): compiles on wasm --- lampada/src/connection/write.rs | 11 ++--------- 1 file changed, 2 insertions(+), 9 deletions(-) (limited to 'lampada/src/connection/write.rs') 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 { -- cgit