Struct LoopbackBroker 

pub struct LoopbackBroker { /* private fields */ }

A shared, in-process router for LoopbackTransports.

Clone a single broker into every transport that should share a namespace; a publish on one transport is delivered to every transport whose subscriptions match the topic. The broker is cheap to clone, and all clones share one routing table.

A broker stands for the network its links share, so taking it out of reach with set_reachable is how a test puts every link on it out of range at once, including links a ladder now owns.

Implementations

impl LoopbackBroker

pub fn new() -> Self

Creates an empty broker.

Returns

A broker with no registered transports, in reach.

pub fn set_reachable(&self, reachable: bool)

Takes the broker out of reach, or brings it back.

Out of reach, every link on the broker fails to connect, send, or subscribe with [Error::Transport], the error an out-of-range radio or a dropped network raises, and nothing is delivered. A link keeps its connection and its filters through the outage, so it carries traffic again as soon as the broker is back.

Arguments

• reachable - false to take the broker out of reach, true to bring it back.

pub fn is_reachable(&self) -> bool

Reports whether the broker is in reach.

Returns

true unless set_reachable took it out.

Trait Implementations

impl Clone for LoopbackBroker

fn clone(&self) -> LoopbackBroker

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for LoopbackBroker

fn default() -> Self

Returns the “default value” for a type.