Struct Subscriber

pub struct Subscriber { /* private fields */ }

Transport subscriber

Methods from Deref<Target = ReceiverStream<Message>>

pub fn close(&mut self)

Closes the receiving half of a channel without dropping it.

This prevents any further messages from being sent on the channel while still enabling the receiver to drain messages that are buffered. Any outstanding Permit values will still be able to send messages.

To guarantee no messages are dropped, after calling close(), you must receive all items from the stream until None is returned.

Trait Implementations

impl Deref for Subscriber

type Target = ReceiverStream<Message>

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl DerefMut for Subscriber

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.

impl Drop for Subscriber

fn drop(&mut self)

Executes the destructor for this type.