bbq2 0.4.3

A SPSC, lockless, no_std, thread safe, queue, based on BipBuffers
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

//! "Notification" functionality
//!
//! This functionality allows (or doesn't allow) for awaiting a read/write grant

use const_init::ConstInit;

#[cfg(feature = "maitake-sync-0_2")]
pub mod maitake;

pub mod blocking;

/// Non-async notifications
pub trait Notifier: ConstInit {
    fn wake_one_consumer(&self);
    fn wake_one_producer(&self);
}

/// Async notifications
#[allow(async_fn_in_trait)]
pub trait AsyncNotifier: Notifier {
    async fn wait_for_not_empty<T, F: FnMut() -> Option<T>>(&self, f: F) -> T;
    async fn wait_for_not_full<T, F: FnMut() -> Option<T>>(&self, f: F) -> T;
}