Trait ipc_queue::AsyncSynchronizer

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>>>>

block execution until the specified event happens.

fn notify(&self, event: QueueEvent)

notify all waiters blocked on the specified event for the same Fifo.

Implementors