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.

Uses a two-phase spin strategy: bare spin for the first 64 iterations (minimum wakeup latency, ~0 ns reaction time), then PAUSE-based spin (saves power, yields to SMT sibling). On Skylake+, PAUSE adds ~140 cycles of delay per iteration — the bare-spin phase avoids this penalty when the message arrives quickly (typical for cross-thread pub/sub).

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>