Struct TaskSlot 

pub struct TaskSlot<R, E> { /* private fields */ }

Runner-side slot for one task submission.

This low-level endpoint is exposed so custom executor services built on top of qubit-executor can wire their own scheduling while still returning the standard crate::TaskHandle. Executor implementations should call Self::accept only after submission succeeds; this arms lifecycle hook reporting for later start and finish events. Normal callers should use crate::TaskHandle and executor/service submission methods instead.

Implementations

impl<R, E> TaskSlot<R, E>

pub fn accept(&self)

Marks this runner endpoint as accepted and arms lifecycle hook reporting.

Calling this method emits on_accepted before any later on_started or on_finished event for the same task. Executor implementations must call it only after submission has succeeded. Dropping a slot before acceptance still releases result waiters with Dropped, but does not emit lifecycle hook events for a task that was rejected before acceptance.

pub fn run<C>(self, task: C) -> bool

where C: Callable<R, E>,

Starts this slot and runs a callable to completion.

Parameters

• task - Callable to run if the task has not been cancelled.

Returns

true if the callable ran and published a result, or false if the task had already been cancelled.

Trait Implementations

impl<R, E> Drop for TaskSlot<R, E>

fn drop(&mut self)

Publishes a dropped-result error when the runner endpoint is abandoned.

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.