Struct NotificationQueue 

pub struct NotificationQueue { /* private fields */ }

An unbounded queue that helps with simulation of registering event sources with Poll. It keeps track of NotificationIds associated with Waker

Implementations

impl NotificationQueue

pub fn new(waker: Arc<Waker>) -> NotificationQueue

Creates a notification queue

pub fn push(&self, id: NotificationId) -> Result<()>

Queues the NotificationId and notifies the Poll associated with Waker

pub fn pop(&self) -> Option<NotificationId>

Attempts to remove an element from the queue If the queue is empty, None is returned.

pub fn is_empty(&self) -> bool

Returns true if the queue is empty

pub fn len(&self) -> usize

Returns queue length

Trait Implementations

impl Debug for NotificationQueue

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

Formats the value using the given formatter.

impl NotificationReceiver for NotificationQueue

fn receive(&self) -> Option<NotificationId>

Retrieves the next notification, if there’s any

fn len(&self) -> usize

Returns number of notifications

fn is_empty(&self) -> bool

Returns true if the queue is empty.

impl Notifier for NotificationQueue

fn notify(&self, id: NotificationId) -> Result

Notifies Poll