Struct BmpClient

pub struct BmpClient { /* private fields */ }

BmpClient

Holds the TcpStream and Decoder state

let client = BmpClient::new(tcp_stream)?;
let decoded_message = client.recv()?;

Implementations

impl BmpClient

pub fn new(stream: TcpStream) -> Self

Instantiate a new client

pub async fn recv(&mut self) -> Option<Result<BmpMessage, Error>>

Returns a Future that will resolve to the next message

Returns an error if the client disconnects or if there is an error decoding the message

pub fn connected(&self) -> Duration

Return a Duration representing how long this client has been connected

pub fn messages(&self) -> usize

Return the number of messages received from this client during the active session

Trait Implementations

impl Debug for BmpClient

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

Formats the value using the given formatter.