1use crate::{
2 rb::AsyncRb,
3 wrap::{AsyncCons, AsyncProd},
4};
5use ringbuf::{storage::Array, SharedRb};
6#[cfg(feature = "alloc")]
7use ringbuf::{storage::Heap, HeapRb};
8
9#[cfg(all(feature = "alloc", not(feature = "portable-atomic")))]
10pub use alloc::sync::Arc;
11#[cfg(all(feature = "alloc", feature = "portable-atomic"))]
12pub use portable_atomic_util::Arc;
13
14#[cfg(feature = "alloc")]
15pub type AsyncHeapRb<T> = AsyncRb<Heap<T>>;
16#[cfg(feature = "alloc")]
17pub type AsyncHeapProd<T> = AsyncProd<Arc<AsyncHeapRb<T>>>;
18#[cfg(feature = "alloc")]
19pub type AsyncHeapCons<T> = AsyncCons<Arc<AsyncHeapRb<T>>>;
20
21#[cfg(feature = "alloc")]
22impl<T> AsyncHeapRb<T> {
23 pub fn new(cap: usize) -> Self {
24 Self::from(HeapRb::new(cap))
25 }
26}
27
28pub type AsyncStaticRb<T, const N: usize> = AsyncRb<Array<T, N>>;
29pub type AsyncStaticProd<'a, T, const N: usize> = AsyncProd<&'a AsyncStaticRb<T, N>>;
30pub type AsyncStaticCons<'a, T, const N: usize> = AsyncCons<&'a AsyncStaticRb<T, N>>;
31
32impl<T, const N: usize> Default for AsyncRb<Array<T, N>> {
33 fn default() -> Self {
34 AsyncRb::from(SharedRb::default())
35 }
36}