Function create

clock-bound/src/daemon/async_ring_buffer.rs:51–58

Create a new Sender-Receiver pair async ring buffer See [module level documentation](self) for more information. # Panics Panics if size is 0

(size: usize)

/// # Panics
/// Panics if size is 0
pub fn create<T>(size: usize) -> (Sender<T>, Receiver<T>) {
    assert!(size > 0, "Ring buffer size must be greater than 0");
    let buffer = Arc::new(Mutex::new(Buffer::new(size)));
    let notifier = Arc::new(Notify::new());
    let tx = Sender::new(Arc::clone(&buffer), Arc::clone(&notifier));
    let rx = Receiver::new(buffer, notifier);
    (tx, rx)
}

/// The sender half of a ring buffer SPSC
///