Class Buffer

clock-bound/src/daemon/async_ring_buffer.rs:202–208

/// Shared data between the paired [`Tx`] and [`Rx`]
#[derive(Debug)]
struct Buffer<T> {
    data: VecDeque<T>,
    capacity: usize,
    sender_dropped: bool,
    receiver_dropped: bool,
    disruption_handled: Option<Side>,
}

impl<T> Buffer<T> {
    fn new(capacity: usize) -> Self {