Struct Sender

pub struct Sender<Tx: WireTx> { /* private fields */ }

The Sender type wraps a WireTx impl, and provides higher level functionality over it

Implementations

impl<Tx: WireTx> Sender<Tx>

pub fn new(tx: Tx, kkind: VarKeyKind) -> Self

Create a new Sender

Takes a WireTx impl, as well as the VarKeyKind used when sending messages to the client.

kkind should usually come from Dispatch::min_key_len().

pub async fn reply<E>( &self, seq_no: VarSeq, resp: &E::Response, ) -> Result<(), Tx::Error>

where E: Endpoint, E::Response: Serialize + Schema,

Send a reply for the given endpoint

pub async fn reply_keyed<T>( &self, seq_no: VarSeq, key: Key, resp: &T, ) -> Result<(), Tx::Error>

where T: ?Sized + Serialize + Schema,

Send a reply with the given Key

This is useful when replying with “unusual” keys, for example Error responses not tied to any specific Endpoint.

pub async fn publish<T>( &self, seq_no: VarSeq, msg: &T::Message, ) -> Result<(), Tx::Error>

where T: ?Sized + Topic, T::Message: Serialize + Schema,

Publish a Topic message

pub async fn log_str(&self, msg: &str) -> Result<(), Tx::Error>

Log a str directly to the LoggingTopic

pub async fn log_fmt(&self, msg: Arguments<'_>) -> Result<(), Tx::Error>

Format a message to the LoggingTopic

pub async fn error( &self, seq_no: VarSeq, error: WireError, ) -> Result<(), Tx::Error>

Send a single error message

pub async fn send_all_schemas( &self, hdr: &VarHeader, device_map: &DeviceMap, ) -> Result<(), Tx::Error>

Implements the GetAllSchemasEndpoint endpoint

Trait Implementations

impl<Tx: Clone + WireTx> Clone for Sender<Tx>

fn clone(&self) -> Sender<Tx>

Returns a copy of the value.

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

Performs copy-assignment from source.