Struct PubSubSubscriber 

pub struct PubSubSubscriber { /* private fields */ }

Subscriber-side helper that holds a SubscriberPosition and pulls items from a PubSubRing in order.

Implementations

impl PubSubSubscriber

pub fn new(ring: Arc<PubSubRing>, position: SubscriberPosition) -> Self

Wrap a ring + position into a subscriber.

pub fn position(&self) -> u64

Current absolute position this subscriber has consumed up to.

pub fn ring(&self) -> &Arc<PubSubRing>

Ring this subscriber is attached to.

pub fn skip(&self, n: u64) -> u64

Advance the subscriber’s position by n without reading. Used by callers that want to skip items deliberately (sampled subscriptions, late-join skip-ahead).

pub fn try_next(&self, out: &mut [u8]) -> Result<(), PubSubReadError>

Try to read the next item. On success, advances the subscriber’s position by 1. On Pending, leaves the position alone. On Lost, advances the position to the ring’s current head (skipping past the gap).