me/iced
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Collect the platform-specific concrete future implementations into mods.

Browse source
This commit is contained in:
Tanner Rogalsky 2021-11-14 11:03:15 -05:00
parent 4cb3820a4e
commit 55eaeceec8
1 changed files with 47 additions and 22 deletions
Download patch file Download diff file Expand all files Collapse all files

69
futures/src/lib.rs
View file

@ -37,33 +37,58 @@ pub mod time;
pub use command::Command; pub use command::Command;
pub use executor::Executor; pub use executor::Executor;
pub use platform::*;
pub use runtime::Runtime; pub use runtime::Runtime;
pub use subscription::Subscription; pub use subscription::Subscription;
/// A boxed static future.
///
/// - On native platforms, it needs a `Send` requirement.
/// - On the Web platform, it does not need a `Send` requirement.
#[cfg(not(target_arch = "wasm32"))] #[cfg(not(target_arch = "wasm32"))]
pub type BoxFuture<T> = futures::future::BoxFuture<'static, T>; mod platform {
/// A boxed static future.
///
/// - On native platforms, it needs a `Send` requirement.
/// - On the Web platform, it does not need a `Send` requirement.
pub type BoxFuture<T> = futures::future::BoxFuture<'static, T>;
/// A boxed static stream.
///
/// - On native platforms, it needs a `Send` requirement.
/// - On the Web platform, it does not need a `Send` requirement.
pub type BoxStream<T> = futures::stream::BoxStream<'static, T>;
/// Boxes a stream.
///
/// - On native platforms, it needs a `Send` requirement.
/// - On the Web platform, it does not need a `Send` requirement.
pub fn boxed_stream<T, S>(stream: S) -> BoxStream<T>
where
S: futures::Stream<Item = T> + Send + 'static,
{
futures::stream::StreamExt::boxed(stream)
}
}
/// A boxed static future.
///
/// - On native platforms, it needs a `Send` requirement.
/// - On the Web platform, it does not need a `Send` requirement.
#[cfg(target_arch = "wasm32")] #[cfg(target_arch = "wasm32")]
pub type BoxFuture<T> = futures::future::LocalBoxFuture<'static, T>; mod platform {
/// A boxed static future.
///
/// - On native platforms, it needs a `Send` requirement.
/// - On the Web platform, it does not need a `Send` requirement.
pub type BoxFuture<T> = futures::future::LocalBoxFuture<'static, T>;
/// A boxed static stream. /// A boxed static stream.
/// ///
/// - On native platforms, it needs a `Send` requirement. /// - On native platforms, it needs a `Send` requirement.
/// - On the Web platform, it does not need a `Send` requirement. /// - On the Web platform, it does not need a `Send` requirement.
#[cfg(not(target_arch = "wasm32"))] pub type BoxStream<T> = futures::stream::LocalBoxStream<'static, T>;
pub type BoxStream<T> = futures::stream::BoxStream<'static, T>;
/// A boxed static stream. /// Boxes a stream.
/// ///
/// - On native platforms, it needs a `Send` requirement. /// - On native platforms, it needs a `Send` requirement.
/// - On the Web platform, it does not need a `Send` requirement. /// - On the Web platform, it does not need a `Send` requirement.
#[cfg(target_arch = "wasm32")] pub fn boxed_stream<T, S>(stream: S) -> BoxStream<T>
pub type BoxStream<T> = futures::stream::LocalBoxStream<'static, T>; where
S: futures::Stream<Item = T> + 'static,
{
futures::stream::StreamExt::boxed_local(stream)
}
}