Struct SendMany 

pub struct SendMany<M, D, R> { /* private fields */ }

Returned by MpcParty::send_many()

Trait Implementations

impl<M, D, E, AsyncR> SendMany for SendMany<M, D, AsyncR>

where M: ProtocolMsg + 'static, D: Stream<Item = Result<Incoming<M>, E>> + Unpin + Sink<Outgoing<M>, Error = E>, AsyncR: AsyncRuntime,

type Exec = MpcParty<M, D, AsyncR, true>

MPC executor, returned after successful .flush()

type Msg = <MpcParty<M, D, AsyncR> as Mpc>::Msg

Protocol message

type SendErr = <MpcParty<M, D, AsyncR> as Mpc>::SendErr

Error indicating that sending a message has failed

async fn send(&mut self, msg: Outgoing<Self::Msg>) -> Result<(), Self::SendErr>

Adds a message to the sending queue

async fn flush(self) -> Result<Self::Exec, Self::SendErr>

Flushes internal buffer by sending all messages in the queue

async fn send_p2p( &mut self, recipient: PartyIndex, msg: Self::Msg, ) -> Result<(), Self::SendErr>

Adds a p2p message to the sending queue

async fn send_to_all(&mut self, msg: Self::Msg) -> Result<(), Self::SendErr>

Adds a broadcast message to the sending queue

async fn reliably_broadcast( &mut self, msg: Self::Msg, ) -> Result<(), Self::SendErr>

Adds a reliable broadcast message to the sending queue