Struct ChannelWireTx

pub struct ChannelWireTx { /* private fields */ }

A WireTx impl using tokio mpsc channels

Implementations

impl ChannelWireTx

pub fn new(tx: Sender<Vec<u8>>) -> Self

Create a new ChannelWireTx

pub fn set_stopper(&mut self, stopper: Stopper)

Add a stopper to listen for “close” methods

Trait Implementations

impl Clone for ChannelWireTx

fn clone(&self) -> ChannelWireTx

Returns a copy of the value.

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

Performs copy-assignment from source.

impl WireTx for ChannelWireTx

type Error = ChannelWireTxError

The error type of this connection.

async fn send<T: Serialize + ?Sized>( &self, hdr: VarHeader, msg: &T, ) -> Result<(), Self::Error>

Send a single frame to the client, returning when send is complete.

async fn send_raw(&self, buf: &[u8]) -> Result<(), Self::Error>

Send a single frame to the client, without handling serialization

async fn send_log_str( &self, kkind: VarKeyKind, s: &str, ) -> Result<(), Self::Error>

Send a logging message on the LoggingTopic

async fn send_log_fmt<'a>( &self, kkind: VarKeyKind, a: Arguments<'a>, ) -> Result<(), Self::Error>

Send a logging message on the LoggingTopic