Struct Subscriber 

pub struct Subscriber<T: Copy> { /* private fields */ }

The read side of a Photon SPMC channel.

Each subscriber has its own cursor — no contention between consumers.

Implementations

impl<T: Copy> Subscriber<T>

pub fn try_recv(&mut self) -> Result<T, TryRecvError>

Try to receive the next message without blocking.

pub fn recv(&mut self) -> T

Spin until the next message is available and return it.

pub fn latest(&mut self) -> Option<T>

Skip to the latest published message (discards intermediate ones).

Returns None only if nothing has been published yet. Under heavy producer load, retries internally if the target slot is mid-write.

pub fn pending(&self) -> u64

How many messages are available to read (capped at ring capacity).

Trait Implementations

impl<T: Copy + Send> Send for Subscriber<T>