Struct EventQ 

pub struct EventQ { /* private fields */ }

Events storage and processor

Should be single instance per poll loop. events is a event storage that shared by reference with the senders. sender shared between notifiers thread to expose custom messages to the poll loop

Implementations

impl EventQ

pub fn new(poll: &Poll, token: Token, num_events: usize) -> Result<Self>

Create new EventQ. Register Waker into the exist Poll instance and create shared storage for the specified number of events

pub fn get_sender(&self) -> EventQSender

Get the cloned EventQSender

pub fn triggered_events(&self) -> EventQIterator

Iterator for pending events. Created over the already triggered events at the moment. All events in the EventQ are reset before the iterator is created, which allows triggering new events and scheduling the poll wake during current proccesing