Struct BacnetScTransport 

pub struct BacnetScTransport { /* private fields */ }

A DataLink implementation that transports BACnet frames over a WebSocket connection (BACnet/SC).

Concurrent receive safety

Unlike a UDP socket, a single WebSocket connection delivers frames sequentially. To avoid frame stealing between concurrent recv() callers (e.g. a who_is discovery loop and a confirmed-request response loop running in the same task via tokio::select!), inbound frames are published through a broadcast channel so that every concurrent caller sees every frame and discards what it doesn’t need.

Implementations

impl BacnetScTransport

pub async fn connect( endpoint: impl Into<String>, ) -> Result<BacnetScTransport, DataLinkError>

pub fn endpoint(&self) -> &str

pub fn peer_address(&self) -> DataLinkAddress

Trait Implementations

impl Clone for BacnetScTransport

fn clone(&self) -> BacnetScTransport

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl DataLink for BacnetScTransport

async fn send( &self, _address: DataLinkAddress, payload: &[u8], ) -> Result<(), DataLinkError>

Sends payload to the given data-link address.

async fn recv( &self, buf: &mut [u8], ) -> Result<(usize, DataLinkAddress), DataLinkError>

Receives a frame into buf, returning (bytes_read, source_address).

impl Debug for BacnetScTransport

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

Formats the value using the given formatter.