Struct Hub 

pub struct Hub { /* private fields */ }

Available on crate feature hub only.

The shared frame bus. Create with Hub::new and attach ports.

Hub is always used behind an Arc so that listener and uplink tasks can share it. It holds no sockets itself: tasks such as serve_tcp attach a Port per connection and drop it when the connection ends.

Implementations

impl Hub

pub fn new() -> Arc<Hub>

Create an empty hub with no ports.

pub fn port(&self) -> Port

Attach a new port. Frames it sends go to every other port.

The port only receives frames sent after it was created. Dropping the port detaches it.

use rolcb::hub::Hub;

let hub = Hub::new();
let a = hub.port();
let mut b = hub.port();
let frame = rolcb::gridconnect::parse(":X10700285N;").unwrap();
a.send(frame);
assert_eq!(b.recv().await, Some(frame));

pub fn port_count(&self) -> usize

Number of ports currently attached (including ones created with Hub::port by the application). Falls as ports are dropped.

Trait Implementations

impl Debug for Hub

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

Formats the value using the given formatter.