Method send

clock-bound/src/daemon/async_ring_buffer.rs:83–95

(&self, value: T)

    /// is available to receive messages.
    #[expect(clippy::missing_panics_doc, reason = "not handling poisoned mutex")]
    pub fn send(&self, value: T) -> Result<(), SendError<T>> {
        let mut guard = self.inner.lock().unwrap();
        if guard.receiver_dropped {
            return Err(BufferClosedError.into());
        }
        if let Some(Side::Receiver) = guard.disruption_handled {
            return Err(SendError::Disrupted(value));
        }
        guard.push(value);
        drop(guard);
        self.notifier.notify_one();
        Ok(())
    }

    /// Handle a clock disruption event
    ///