Struct Transceiver 

pub struct Transceiver<TyTx, TyRx, TrTx, TrRx, C: CodecFor<TyTx> + CodecFor<TyRx>> { /* private fields */ }

A typed, multidirectional endpoint pairing a send half and a receive half.

The two halves carry independent transport types: the full-duplex consortium_ipc_transport_memory::SharedMemoryTransport is split into a …Tx send half and a …Rx receive half, and each is the transport of its respective Channel.

Type parameters

• TyTx / TyRx - the sent and received message types
• TrTx - send-half transport (SendTransport)
• TrRx - receive-half transport (RecvTransport)
• C - codec

Implementations

impl<TyTx, TyRx, TrTx, TrRx, C: CodecFor<TyTx> + CodecFor<TyRx>> Transceiver<TyTx, TyRx, TrTx, TrRx, C>

pub fn new( tx: Channel<Tx, TyTx, TrTx, C>, rx: Channel<Rx, TyRx, TrRx, C>, ) -> Self

Create a new Transceiver from a send half and a receive half.

pub fn tx(&self) -> &Channel<Tx, TyTx, TrTx, C>

Get the send half of the transceiver.

pub fn rx(&self) -> &Channel<Rx, TyRx, TrRx, C>

Get the receive half of the transceiver.

pub fn split(self) -> (Channel<Tx, TyTx, TrTx, C>, Channel<Rx, TyRx, TrRx, C>)

split into two channels

impl<TyTx, TyRx, TrTx, TrRx, C> Transceiver<TyTx, TyRx, TrTx, TrRx, C>

where TrTx: SendTransport, C: CodecFor<TyTx> + CodecFor<TyRx>,

pub async fn send(&mut self, msg: &TyTx) -> Result<(), ChannelError<C, TrTx>>

send message

impl<TyTx, TyRx, TrTx, TrRx, C> Transceiver<TyTx, TyRx, TrTx, TrRx, C>

where TrRx: RecvTransport, C: CodecFor<TyTx> + CodecFor<TyRx>,

pub async fn recv( &mut self, ) -> Result<ReceivedMessage<'_, TyRx, C>, ChannelError<C, TrRx>>

receive message