Struct Mailbox 

pub struct Mailbox<P: PublicKey, M: Digestible + Codec> { /* private fields */ }

Ingress mailbox for super::Engine.

Implementations

impl<P: PublicKey, M: Digestible + Codec> Mailbox<P, M>

pub fn subscribe(&self, digest: M::Digest) -> Receiver<Arc<M>>

Subscribe to a message by digest.

The responder will be sent the message when it is available; either instantly (if cached) or when it is received from the network. The request can be canceled by dropping the responder.

If the engine has shut down, the returned receiver will resolve to Canceled.

pub async fn get(&self, digest: M::Digest) -> Option<Arc<M>>

Get a message by digest.

If the engine has shut down, returns None.

pub fn broadcast_shared( &self, recipients: Recipients<P>, message: Arc<M>, ) -> Feedback

Broadcast a shared message to recipients.

If the engine has shut down, returns Feedback::Closed.

Trait Implementations

impl<P: PublicKey, M: Digestible + Codec> Broadcaster for Mailbox<P, M>

fn broadcast( &self, recipients: Self::Recipients, message: Self::Message, ) -> Feedback

Broadcast a message to recipients.

If the engine has shut down, returns Feedback::Closed.

type Recipients = Recipients<P>

The type of recipients that can receive messages.

type Message = M

Message is the type of data that can be broadcasted.

impl<P: Clone + PublicKey, M: Clone + Digestible + Codec> Clone for Mailbox<P, M>

fn clone(&self) -> Mailbox<P, M>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.