Struct Server

pub struct Server<Tx, Rx, Buf, D>
where
    Tx: WireTx,
    Rx: WireRx,
    Buf: DerefMut<Target = [u8]>,
    D: Dispatch<Tx = Tx>,
{ /* private fields */ }

The Server is the main interface for handling communication

Implementations

impl<Tx, Rx, Buf, D> Server<Tx, Rx, Buf, D>

where Tx: WireTx, Rx: WireRx, Buf: DerefMut<Target = [u8]>, D: Dispatch<Tx = Tx>,

pub fn new(tx: Tx, rx: Rx, buf: Buf, dis: D, kkind: VarKeyKind) -> Self

Create a new Server

Takes:

• a WireTx impl for sending
• a WireRx impl for receiving
• a buffer used for receiving frames
• The user provided dispatching method, usually generated by define_dispatch!()
• a VarKeyKind, which controls the key sizes sent by the WireTx impl

pub async fn run(&mut self) -> ServerError<Tx, Rx>

Run until a fatal error occurs

The server will receive frames, and dispatch them. When a fatal error occurs, this method will return with the fatal error.

The caller may decide to wait until a connection is re-established, reset any state, or immediately begin re-running.

impl<Tx, Rx, Buf, D> Server<Tx, Rx, Buf, D>

where Tx: WireTx + Clone, Rx: WireRx, Buf: DerefMut<Target = [u8]>, D: Dispatch<Tx = Tx>,

pub fn sender(&self) -> Sender<Tx>

Get a copy of the Sender to pass to tasks that need it