Struct EventPublisher 

pub struct EventPublisher<T> { /* private fields */ }

The write side. Single producer: &mut self enforces it without atomics.

Implementations

impl<T> EventPublisher<T>

pub fn publish(&mut self, f: impl FnOnce(&mut T))

Fill the next slot, blocking until a subscriber frees one.

The closure receives the slot’s existing value to mutate. Nothing is allocated or copied, so a payload that owns a String or Vec reuses the capacity it had from the previous time round the ring.

If the closure panics the value is left as the closure altered it — still a valid T — and the message is not published.

pub fn try_publish(&mut self, f: impl FnOnce(&mut T)) -> bool

Fill the next slot, or return false if that would overtake a subscriber.

pub fn published(&self) -> u64

Messages published so far.

pub fn capacity(&self) -> u64

Ring capacity.

Trait Implementations

impl<T: Send + Sync> Send for EventPublisher<T>