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 async fn subscribe(&self, digest: M::Digest) -> Receiver<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 subscribe_prepared(&self, digest: M::Digest, responder: Sender<M>)

Subscribe to a message by digest with an externally prepared responder.

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, this is a no-op.

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

Get a message by digest.

If the engine has shut down, returns None.

Trait Implementations

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

async fn broadcast( &self, recipients: Self::Recipients, message: Self::Message, ) -> Receiver<Self::Response>

Broadcast a message to recipients.

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

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.

type Response = Vec<P>

The type of data that is returned once the message is 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.