Struct Broker 

pub struct Broker {
    pub(crate) listener: TcpListener,
}

A TCP listener that hands out scripted MQTT connections.

Fields

listener: TcpListener

Implementations

impl Broker

pub async fn bind() -> Self

Binds to an ephemeral IPv6 port.

Listening on [::] accepts IPv6 clients and, on the usual dual-stack configuration, IPv4-mapped clients (e.g. 127.0.0.1) too. On a rare IPv6-only host, clients simply connect over IPv6.

Panics

Panics if binding fails.

pub fn port(&self) -> u16

The TCP port the fake broker is listening on.

Panics

Panics if the listener’s local address cannot be queried.

pub fn host(&self) -> &'static str

The loopback host a client should connect to, matching the bound address family. Pair it with port so test code never has to assume IPv4 or dual-stack.

pub async fn accept(&self) -> Conn

Accepts the next client connection.

Panics

Panics if no client connects within 10 s.

pub async fn try_accept(&self, dur: Duration) -> Option<Conn>

Accepts the next client connection, returning None if no client connects within dur.

Panics

Panics on listener I/O errors.