Struct Subscriber 

pub struct Subscriber { /* private fields */ }

A subscriber that receives GameEvent values from an EventBus.

Wraps a tokio::sync::broadcast::Receiver. When the subscriber falls behind (the sender has overwritten messages it hasn’t read), the next call to recv logs a warning and skips ahead to the oldest available message.

Implementations

impl Subscriber

pub async fn recv(&mut self) -> Option<GameEvent>

Receives the next GameEvent, waiting asynchronously.

If the subscriber has fallen behind, the lagged messages are skipped, a warning is logged, and the next available event is returned.

Returns None if the sender (event bus) has been dropped and there are no more buffered messages.

Trait Implementations

impl Debug for Subscriber

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.