Struct TunnelEvents 

pub struct TunnelEvents { /* private fields */ }

A tunnel’s events as they happen, after the history it has kept: from subscribe_events on a Registration or a Connection.

Every subscriber reads at its own pace from its own queue. One that falls more than 128 events behind is told how many it missed, and goes on from there. A subscription does not keep its tunnel alive: once the tunnel stops and its cleanup has reported, the stream ends.

Implementations

impl TunnelEvents

pub async fn recv(&mut self) -> Option<Result<TunnelEvent, EventsLagged>>

The next event, or None once the stream has ended. An error says events were missed; the tunnel’s diagnostics() is the state to reconcile with, and the stream goes on. Cancel-safe.