diff --git a/runtime/src/task.rs b/runtime/src/task.rs index d1864473ca..b2755e8de6 100644 --- a/runtime/src/task.rs +++ b/runtime/src/task.rs @@ -159,6 +159,21 @@ impl Task { } } + /// Creates a new [`Task`] that can be aborted with the returned [`Handle`]. + pub fn abortable(self) -> (Self, Handle) + where + T: 'static, + { + match self.0 { + Some(stream) => { + let (stream, handle) = stream::abortable(stream); + + (Self(Some(boxed_stream(stream))), Handle(Some(handle))) + } + None => (Self(None), Handle(None)), + } + } + /// Creates a new [`Task`] that runs the given [`Future`] and produces /// its output. pub fn future(future: impl Future + MaybeSend + 'static) -> Self @@ -178,6 +193,28 @@ impl Task { } } +/// A handle to a [`Task`] that can be used for aborting it. +#[derive(Debug, Clone)] +pub struct Handle(Option); + +impl Handle { + /// Aborts the [`Task`] of this [`Handle`]. + pub fn abort(&self) { + if let Some(handle) = &self.0 { + handle.abort() + } + } + + /// Returns `true` if the [`Task`] of this [`Handle`] has been aborted. + pub fn is_aborted(&self) -> bool { + if let Some(handle) = &self.0 { + handle.is_aborted() + } else { + true + } + } +} + impl Task> { /// Executes a new [`Task`] after this one, only when it produces `Some` value. /// diff --git a/src/lib.rs b/src/lib.rs index 09d9860e2f..79e2f276ff 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -202,9 +202,14 @@ pub use crate::core::{ Length, Padding, Pixels, Point, Radians, Rectangle, Rotation, Shadow, Size, Theme, Transformation, Vector, }; -pub use crate::runtime::{exit, Task}; +pub use crate::runtime::exit; pub use iced_futures::Subscription; +pub mod task { + //! Create runtime tasks. + pub use crate::runtime::task::{Handle, Task}; +} + pub mod clipboard { //! Access the clipboard. pub use crate::runtime::clipboard::{ @@ -309,6 +314,7 @@ pub use executor::Executor; pub use font::Font; pub use renderer::Renderer; pub use settings::Settings; +pub use task::Task; #[doc(inline)] pub use application::application;