Struct BoundedNotificationQueue 

pub struct BoundedNotificationQueue { /* private fields */ }

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

Implementations

impl BoundedNotificationQueue

pub fn new(size: usize, waker: Arc<Waker>) -> BoundedNotificationQueue

Creates the 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 BoundedNotificationQueue

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

Formats the value using the given formatter.

impl NotificationReceiver for BoundedNotificationQueue

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 BoundedNotificationQueue

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

Notifies Poll