Struct Mailbox

pub struct Mailbox<P: Array, D: Digest, M: Digestible<D>> { /* private fields */ }

Ingress mailbox for Engine.

Implementations

impl<P: Array, D: Digest, M: Digestible<D>> Mailbox<P, D, M>

pub async fn subscribe(&mut self, digest: D) -> 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.

pub async fn subscribe_prepared(&mut self, digest: D, sender: Sender<M>)

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

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.

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

Get a message by digest.

Trait Implementations

impl<Cfg: Config, P: Array, D: Digest, M: Codec<Cfg> + Digestible<D>> Broadcaster<Cfg> for Mailbox<P, D, M>

type Message = M

Message is the type of data that can be broadcasted.

type Response = Vec<P>

Response is the type of data that is returned once the message is broadcasted.

async fn broadcast(&mut self, message: Self::Message) -> Receiver<Vec<P>>

Attempt to broadcast a message to the network.

impl<P: Clone + Array, D: Clone + Digest, M: Clone + Digestible<D>> Clone for Mailbox<P, D, M>

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

Returns a copy of the value.

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

Performs copy-assignment from source.