81 lines
2.5 KiB
Rust
81 lines
2.5 KiB
Rust
//! Asynchronous tasks for GUI programming, inspired by Elm.
|
|
//!
|
|
//! 
|
|
#![doc(
|
|
html_logo_url = "https://raw.githubusercontent.com/iced-rs/iced/9ab6923e943f784985e9ef9ca28b10278297225d/docs/logo.svg"
|
|
)]
|
|
#![deny(missing_docs)]
|
|
#![deny(missing_debug_implementations)]
|
|
#![deny(unused_results)]
|
|
#![forbid(unsafe_code)]
|
|
#![forbid(rust_2018_idioms)]
|
|
#![cfg_attr(docsrs, feature(doc_cfg))]
|
|
|
|
pub use futures;
|
|
|
|
mod command;
|
|
mod maybe_send;
|
|
mod runtime;
|
|
|
|
pub mod backend;
|
|
pub mod executor;
|
|
pub mod subscription;
|
|
|
|
pub use command::Command;
|
|
pub use executor::Executor;
|
|
pub use maybe_send::MaybeSend;
|
|
pub use platform::*;
|
|
pub use runtime::Runtime;
|
|
pub use subscription::Subscription;
|
|
|
|
#[cfg(not(target_arch = "wasm32"))]
|
|
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)
|
|
}
|
|
}
|
|
|
|
#[cfg(target_arch = "wasm32")]
|
|
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.
|
|
///
|
|
/// - 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::LocalBoxStream<'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> + 'static,
|
|
{
|
|
futures::stream::StreamExt::boxed_local(stream)
|
|
}
|
|
}
|