Struct ConnectionStateStream 

pub struct ConnectionStateStream<'a> { /* private fields */ }

Available on crate feature async only.

Async stream of ConnectionStateEvent for a crate::client::TcpClient.

Implementations

impl<'a> ConnectionStateStream<'a>

pub fn subscribe(client: &'a TcpClient, capacity: usize) -> Self

Subscribe to connection state changes.

pub const fn next(&self) -> NextItem<'_, ConnectionStateEvent>

Asynchronously wait for the next event.

pub fn try_next(&self) -> Option<ConnectionStateEvent>

Try to get an event without blocking.

pub fn buffered_count(&self) -> usize

Number of events currently buffered.

Trait Implementations

impl<'a> Debug for ConnectionStateStream<'a>

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

Formats the value using the given formatter.