Struct DispatcherTaskScheduler 

pub struct DispatcherTaskScheduler { /* private fields */ }

Runs futures on a Dispatcher at a fixed priority: every poll of a future started here is a dispatcher job of that priority.

Obtained from Dispatcher::to_task_scheduler or FerroSynchronizationContext::to_task_scheduler.

Implementations

impl DispatcherTaskScheduler

pub fn dispatcher(&self) -> &Arc<Dispatcher>

pub fn priority(&self) -> DispatcherPriority

pub fn spawn<Fut>(&self, future: Fut) -> DispatcherTask<Fut::Output>

where Fut: Future + Send + 'static, Fut::Output: Send + 'static,

Runs future on the dispatcher thread. Can be called from any thread.

pub fn spawn_local<Fut>(&self, future: Fut) -> DispatcherTask<Fut::Output>

where Fut: Future + 'static, Fut::Output: 'static,

Runs a future that is not Send on the dispatcher thread.

Panics

Panics when called from a thread other than the dispatcher thread.

pub fn start_local<Fut>(&self, future: Fut) -> DispatcherTask<Fut::Output>

where Fut: Future + 'static, Fut::Output: 'static,

Starts a future that is not Send on the dispatcher thread the way calling an asynchronous method does: the future is polled for the first time before this returns, so it runs up to its first pending await right away (and the returned task is already complete if there is none). Afterwards it is resumed from dispatcher jobs at the priority of the context.

Panics

Panics when called from a thread other than the dispatcher thread.

Trait Implementations

impl Clone for DispatcherTaskScheduler

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.