Struct SingleSlotTask 

pub struct SingleSlotTask<T> { /* private fields */ }

Implementations

impl<T> SingleSlotTask<T>

pub fn empty() -> Self

pub fn is_in_flight(&self) -> bool

True between spawn and the moment the task’s future finishes (cancellation OR normal return). Cheap; no awaiting.

pub fn abort(&mut self)

Abort the in-flight task (if any) and clear the slot. No-op on an empty slot. abort() is asynchronous — the spawned future is cancelled at its next await point, so a result already sent on a channel may still arrive at its consumer. Consumers are responsible for filtering stale results (e.g. via revision match).

impl<T: Send + 'static> SingleSlotTask<T>

pub fn spawn<F>(&mut self, fut: F) -> AbortHandle

where F: Future<Output = T> + Send + 'static,

Aborts any in-flight task, then spawns fut. Returns the new task’s AbortHandle so callers that want to cancel from somewhere other than the slot’s owner (e.g. an event handler holding a clone) can do so. Usually ignored.

pub async fn await_with_timeout( &mut self, dur: Duration, ) -> Option<Result<T, JoinError>>

Some(result) if the task completed within the deadline. None if the deadline expired — the slot keeps the handle so the caller can decide whether to abort() explicitly. The returned Result is JoinHandle’s own result type, so a panic in the task surfaces as Err(JoinError).

Trait Implementations

impl<T> Drop for SingleSlotTask<T>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.