Struct CompleteQ 

pub struct CompleteQ<E: UserEvent> { /* private fields */ }

CompleteQ structure is a central scheduler for certain types of completion events

The generic parameter E represents a user-defined event type

Implementations

impl<E> CompleteQ<E>

where E: 'static + UserEvent,

pub fn new() -> Self

pub fn cancel_all(&self)

pub fn complete_one( &self, event_id: E::ID, event_arg: E::Argument, ) -> EventSend<E>

pub fn wait_for( &self, event_id: E::ID, max_len: usize, ) -> EventReceiver<E, Timeout>

Create a new event receiver with provide event_id

pub fn wait_for_timeout<T: TimerWithContext>( &self, event_id: E::ID, max_len: usize, timeout: Duration, ) -> EventReceiver<E, T>

wait_for operation with timeout

pub fn wait_for_timeout_with_context<T: TimerWithContext, C>( &self, event_id: E::ID, max_len: usize, timeout: Duration, context: C, ) -> EventReceiver<E, T>

where C: AsMut<T::Context>,

pub fn wait_for_with_timer<T: Timer>( &self, event_id: E::ID, max_len: usize, timer: T, ) -> EventReceiver<E, T>

impl<E> CompleteQ<E>

where E: 'static + AutoIncEvent,

pub fn wait_one(&mut self, max_len: usize) -> EventReceiver<E, Timeout>

Create a new event receiver with automatic generate event_id

pub fn wait_one_with_timer<T: Timer>( &mut self, max_len: usize, timer: T, ) -> EventReceiver<E, T>

pub fn wait_one_timeout<T: Timer>( &mut self, max_len: usize, duration: Duration, ) -> EventReceiver<E, T>

pub fn wait_one_timeout_with_context<T: TimerWithContext, C>( &mut self, max_len: usize, duration: Duration, context: C, ) -> EventReceiver<E, T>

where C: AsMut<T::Context>,

Trait Implementations

impl<E: Clone + UserEvent> Clone for CompleteQ<E>

fn clone(&self) -> CompleteQ<E>

Returns a duplicate of the value.

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

Performs copy-assignment from source.