Struct CapacityPubSubSubscriber 

pub struct CapacityPubSubSubscriber { /* private fields */ }

Subscriber-side handle to a CapacityPubSubRing. Holds its own backing_idx + position within that backing and advances through the chain as it catches up.

Implementations

impl CapacityPubSubSubscriber

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

Try to read the next payload. On Ok, the subscriber advances its position by 1. On Pending at a stale backing’s head, transparently advances to the next backing in the chain and retries; on Pending at the active backing’s head, returns Pending (no more data right now).

pub fn backing_idx(&self) -> u64

Current backing chain index this subscriber is reading.

pub fn position(&self) -> u64

Current position within the current backing.