Struct LiveSubscription 

pub struct LiveSubscription { /* private fields */ }

Receiving end of a live subscription.

Values are delivered as shared LiveEntry handles so one decoded entry can be fanned out to multiple subscribers without duplicating field storage.

Implementations

impl LiveSubscription

pub fn recv(&self) -> Result<Result<LiveEntry>, RecvError>

Receive the next entry, blocking until the subscription closes or a value arrives.

pub fn recv_timeout( &self, timeout: Duration, ) -> Result<Result<LiveEntry>, RecvTimeoutError>

Receive the next entry, waiting at most timeout.

pub fn try_recv(&self) -> Result<Result<LiveEntry>, TryRecvError>

Try to receive the next queued entry without blocking.

Trait Implementations

impl Drop for LiveSubscription

fn drop(&mut self)

Executes the destructor for this type.