Struct PollRegistrar 

pub struct PollRegistrar<M> { /* private fields */ }

Owns every readiness registration made by one polling attempt.

Dropping or resetting a registrar cancels every still-live source lease.

Implementations

impl<M> PollRegistrar<M>

pub fn new(waker: &Waker) -> Self

Creates an empty registrar for waker.

pub fn reset(&mut self, waker: &Waker)

Cancels the previous polling attempt and starts one with waker.

pub fn clear(&mut self)

Cancels every registration owned by this registrar.

pub fn is_empty(&self) -> bool

Returns whether this registrar currently owns no registration.

impl PollRegistrar<SharedObserver>

pub unsafe fn register(&mut self, source: &dyn PollSource, interests: IoEvents)

Registers this observer in source for interests.

Safety

Registration is task/deferred-context only.

impl PollRegistrar<ExclusiveConsumer>

pub fn was_exclusively_notified(&self) -> bool

Returns whether an exclusive source selected this polling attempt.

Consumptive sources use this to transfer still-available readiness to the next exclusive waiter without turning ordinary wakeups into a broadcast.

pub unsafe fn register_exclusive( &mut self, source: &dyn PollSource, interests: IoEvents, )

Registers this consumer as an exclusive waiter.

Safety

Registration is task/deferred-context only.

pub unsafe fn register_shared( &mut self, source: &dyn PollSource, interests: IoEvents, )

Registers this consumer as a shared observer at a composite boundary.

Safety

Registration is task/deferred-context only.

Trait Implementations

impl ExclusiveRegistrationSink for PollRegistrar<ExclusiveConsumer>

fn waker(&self) -> &Waker

Returns the waker owned by this registration attempt.

unsafe fn register_exclusive( &mut self, source: &dyn PollSource, interests: IoEvents, )

Adds an exclusive registration owned by this sink.

fn as_shared(&mut self) -> &mut dyn SharedRegistrationSink

Borrows this sink’s shared-registration capability.

impl SharedRegistrationSink for PollRegistrar<SharedObserver>

fn waker(&self) -> &Waker

Returns the waker owned by this registration attempt.

unsafe fn register_shared( &mut self, source: &dyn PollSource, interests: IoEvents, )

Adds a shared registration owned by this sink.

impl SharedRegistrationSink for PollRegistrar<ExclusiveConsumer>

fn waker(&self) -> &Waker

Returns the waker owned by this registration attempt.

unsafe fn register_shared( &mut self, source: &dyn PollSource, interests: IoEvents, )

Adds a shared registration owned by this sink.