Struct BareConduitTx 

pub struct BareConduitTx<F: MsgFamily, LTx: LinkTx> { /* private fields */ }

Trait Implementations

impl<F: MsgFamily, LTx: LinkTx + MaybeSend + 'static> ConduitTx for BareConduitTx<F, LTx>

type Msg = F

type Prepared = Vec<u8>

type Error = BareConduitError

fn prepare_send(&self, item: F::Msg<'_>) -> Result<Self::Prepared, Self::Error>

Serialize one outbound message into an owned representation.

async fn send_prepared( &self, prepared: Self::Prepared, ) -> Result<(), Self::Error>

Enqueue a previously prepared outbound message.

async fn close(self) -> Result<()>

Graceful close of the outbound direction.