Trait ipc_queue::AsyncSynchronizer
source · [−]pub trait AsyncSynchronizer: Clone {
fn wait(
&self,
event: QueueEvent
) -> Pin<Box<dyn Future<Output = Result<(), SynchronizationError>> + '_>>;
fn notify(&self, event: QueueEvent);
}
Required Methods
fn wait(
&self,
event: QueueEvent
) -> Pin<Box<dyn Future<Output = Result<(), SynchronizationError>> + '_>>
fn wait(
&self,
event: QueueEvent
) -> Pin<Box<dyn Future<Output = Result<(), SynchronizationError>> + '_>>
block execution until the specified event happens.
fn notify(&self, event: QueueEvent)
fn notify(&self, event: QueueEvent)
notify all waiters blocked on the specified event for the same Fifo.