diff options
| author |  cel 🌸 <cel@bunny.garden> | 2025-04-17 11:03:51 +0100 |
|---|---|---|
| committer | cel 🌸 <cel@bunny.garden> | 2025-04-17 11:03:51 +0100 |
| commit | b9d75f38743113c054be3d97af36bdd2a7dd0d69 (patch) | |
| tree | 537623664010d26d5f2574e2d51d03f8c25e08ac /lampada/src/connection/write.rs | |
| parent | cf51dcf052af89f8742d887bde2c93d735309bdd (diff) | |
| download | luz-b9d75f38743113c054be3d97af36bdd2a7dd0d69.tar.gz luz-b9d75f38743113c054be3d97af36bdd2a7dd0d69.tar.bz2 luz-b9d75f38743113c054be3d97af36bdd2a7dd0d69.zip | |
feat(filamento): compiles on wasm
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 { |