Struct RealtimeEventReceiver 

pub struct RealtimeEventReceiver { /* private fields */ }

Single-consumer receiver for real-time events.

Implementations

impl RealtimeEventReceiver

pub fn queued_event_count(&self) -> usize

Number of accepted events waiting for this receiver.

pub fn oldest_event_age(&self) -> Option<Duration>

Age of the oldest accepted event waiting for this receiver.

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.

impl Drop for RealtimeEventReceiver

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.