Struct AsyncDispatcherRef 

pub struct AsyncDispatcherRef<'a>(/* private fields */);

An unowned reference to a driver runtime dispatcher such as is produced by calling [AsyncDispatcher::release]. When this object goes out of scope it won’t shut down the dispatcher, leaving that up to the driver runtime or another owner.

Implementations

impl<'a> AsyncDispatcherRef<'a>

pub unsafe fn from_raw(ptr: NonNull<async_dispatcher_t>) -> Self

Creates a dispatcher ref from a raw ptr.

Safety

Caller is responsible for ensuring that the given ptr is valid for the lifetime 'a.

pub fn inner(&self) -> NonNull<async_dispatcher_t>

Gets the inner pointer to the dispatcher struct.

Trait Implementations

impl<'a> AsyncDispatcher for AsyncDispatcherRef<'a>

fn as_async_dispatcher_ref(&self) -> AsyncDispatcherRef<'_>

Gets an AsyncDispatcherRef corresponding to this object.

fn post_task_sync(&self, p: impl TaskCallback) -> Result<(), Status>

Schedules the callback [p] to be run on this dispatcher later.

fn now(&self) -> MonotonicInstant

Returns the current time on the dispatcher’s timeline

impl<'a> Clone for AsyncDispatcherRef<'a>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a> Debug for AsyncDispatcherRef<'a>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'a> OnDispatcher for AsyncDispatcherRef<'a>

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: From<Status>>( &self, f: impl FnOnce(AsyncDispatcherRef<'_>) -> Result<R, E>, ) -> Result<R, E>

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_task( &self, future: impl Future<Output = ()> + Send + 'static, ) -> Result<(), 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.

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

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

impl<'a> Send for AsyncDispatcherRef<'a>

impl<'a> Sync for AsyncDispatcherRef<'a>