From a844faedd0ae6dafe15f7454e337e39d07883f52 Mon Sep 17 00:00:00 2001 From: Joseph Champagne Date: Wed, 17 Dec 2025 20:11:39 -0700 Subject: [PATCH] Add ConditionalSendStream --- crates/bevy_tasks/src/lib.rs | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/crates/bevy_tasks/src/lib.rs b/crates/bevy_tasks/src/lib.rs index 4ef156170a87e..51dbd0dd53905 100644 --- a/crates/bevy_tasks/src/lib.rs +++ b/crates/bevy_tasks/src/lib.rs @@ -66,6 +66,12 @@ pub trait ConditionalSendFuture: Future + ConditionalSend {} impl ConditionalSendFuture for T {} +/// Use [`ConditionalSendStream`] for a stream with an optional Send trait bound, as on certain platforms (eg. Wasm), +/// futures aren't Send. +pub trait ConditionalSendStream: Stream + ConditionalSend {} + +impl ConditionalSendStream for T {} + use alloc::boxed::Box; /// An owned and dynamically typed Future used when you can't statically type your result or need to add some indirection. @@ -85,6 +91,7 @@ cfg::async_executor! { } } +use futures_lite::Stream; // Exports pub use iter::ParallelIterator; pub use slice::{ParallelSlice, ParallelSliceMut};