Struct Dispatcher 

pub struct Dispatcher {}

Implementations

impl Dispatcher

pub fn spawn_local(future: impl Future<Output = ()> + 'static) -> TaskHandle<()>

where Self: 'static,

pub fn after_deadline( deadline: MonotonicInstant, ) -> impl Future<Output = ()> + 'static

pub fn client_from_zx_channel<P>( client_end: ClientEnd<P, Channel>, ) -> ClientEnd<P, Transport>

Trait Implementations

impl Clone for Dispatcher

fn clone(&self) -> Dispatcher

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for Dispatcher

fn default() -> Dispatcher

Returns the “default value” for a type.

impl OnDispatcher for Dispatcher

fn on_dispatcher<R>( &self, f: impl FnOnce(Option<AsyncDispatcherRef<'_>>) -> R, ) -> R

Runs the function f with a lifetime-bound AsyncDispatcherRef for this object’s dispatcher. If the dispatcher is no longer valid, the callback will be given None.

fn on_maybe_dispatcher<R, E>( &self, f: impl FnOnce(AsyncDispatcherRef<'_>) -> Result<R, E>, ) -> Result<R, E>

where E: From<Status>,

Helper version of OnDispatcher::on_dispatcher that translates an invalidated dispatcher handle into a [Status::BAD_STATE] error instead of giving the callback None.

fn spawn( &self, future: impl Future<Output = ()> + Send + 'static, ) -> Result<JoinHandle<()>, Status>

where Self: 'static,

Spawn an asynchronous task on this dispatcher. If this returns Ok then the task has successfully been scheduled and will run or be cancelled and dropped when the dispatcher shuts down. The returned future’s result will be Ok if the future completed successfully, or an Err if the task did not complete for some reason (like the dispatcher shut down).

fn compute<T>( &self, future: impl Future<Output = T> + Send + 'static, ) -> Task<T>

where T: Send + 'static, Self: 'static,

Spawn an asynchronous task that outputs type ‘T’ on this dispatcher. The returned future’s result will be Ok if the task was started and completed successfully, or an Err if the task couldn’t be started or failed to complete (for example because the dispatcher was shutting down).

fn after_deadline( &self, deadline: Instant<MonotonicTimeline>, ) -> AfterDeadline<Self>

Returns a future that will fire when after the given deadline time.