Trait round_based::Delivery
source · pub trait Delivery<M> {
type Send: Sink<Outgoing<M>, Error = Self::SendError> + Unpin;
type Receive: Stream<Item = Result<Incoming<M>, Self::ReceiveError>> + Unpin;
type SendError: StdError + Send + Sync + 'static;
type ReceiveError: StdError + Send + Sync + 'static;
// Required method
fn split(self) -> (Self::Receive, Self::Send);
}
Expand description
Required Associated Types§
sourcetype Receive: Stream<Item = Result<Incoming<M>, Self::ReceiveError>> + Unpin
type Receive: Stream<Item = Result<Incoming<M>, Self::ReceiveError>> + Unpin
Incoming delivery channel
sourcetype ReceiveError: StdError + Send + Sync + 'static
type ReceiveError: StdError + Send + Sync + 'static
Error of incoming delivery channel
Required Methods§
Implementations on Foreign Types§
Implementors§
source§impl<M> Delivery<M> for MockedDelivery<M>
Available on crate feature dev
only.
impl<M> Delivery<M> for MockedDelivery<M>
Available on crate feature
dev
only.