Struct StableConduitTx 

pub struct StableConduitTx<F: MsgFamily, LS: LinkSource> { /* private fields */ }

Trait Implementations

impl<F: MsgFamily, LS> ConduitTx for StableConduitTx<F, LS>

where <LS::Link as Link>::Tx: MaybeSend + 'static, <LS::Link as Link>::Rx: MaybeSend + 'static, LS: MaybeSend + 'static + LinkSource,

type Msg = F

type Prepared = StablePreparedMessage

type Error = StableConduitError

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.