Struct QueuedMaster 

pub struct QueuedMaster { /* private fields */ }

Multi-producer async master backed by a single worker task.

Implementations

impl QueuedMaster

pub async fn new_rs485( path: &str, baud_rate: u32, buffer: usize, ) -> Result<Arc<Self>>

Build a queued master that spawns a worker task for one serial port.

buffer is the queue depth of the internal MPSC channel; requests are buffered up to this limit. Passing 0 will panic in tokio::sync::mpsc::channel.

pub async fn send( &self, req: &Request<'_>, baud_rate: u32, ) -> Result<Response, Error>

Enqueue a request and wait for its response (or a broadcast ack).

Trait Implementations

impl Drop for QueuedMaster

fn drop(&mut self)

Executes the destructor for this type.