Struct RealtimeEventReceiver 

pub struct RealtimeEventReceiver { /* private fields */ }

Single-consumer bounded receiver for real-time events.

Implementations

impl RealtimeEventReceiver

pub fn is_closed(&self) -> bool

Returns whether every producer for this event stream is gone.

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

Receives an event without its socket identity. Use Self::recv_message when work may overlap transport replacement.

pub async fn recv_message(&mut self) -> Option<RealtimeMessage>

Receives the accepted prefix, then retained gap and lifecycle boundaries. A disconnected boundary proves both socket tasks have stopped.

pub fn acknowledge_transport_gap(&mut self)

Resumes data admission after the caller installs its recovery boundary. This never closes a socket. Completions and keepalives continue while fenced.

Trait Implementations

impl Debug for RealtimeEventReceiver

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

Formats the value using the given formatter.