Struct Mailbox 

pub struct Mailbox<V: Variant, B: Block> { /* private fields */ }

A mailbox for sending messages to the marshal Actor.

Implementations

impl<V: Variant, B: Block> Mailbox<V, B>

pub async fn get(&mut self, commitment: B::Commitment) -> Receiver<Option<B>>

Get is a best-effort attempt to retrieve a given block from local storage. It is not an indication to go fetch the block from the network.

pub async fn subscribe( &mut self, view: Option<u64>, commitment: B::Commitment, ) -> Receiver<B>

Subscribe is a request to retrieve a block by its commitment.

If the block is found available locally, the block will be returned immediately.

If the block is not available locally, the request will be registered and the caller will be notified when the block is available. If the block is not finalized, it’s possible that it may never become available.

The oneshot receiver should be dropped to cancel the subscription.

pub async fn broadcast(&mut self, block: B)

Broadcast indicates that a block should be sent to all peers.

pub async fn verified(&mut self, view: u64, block: B)

Notifies the actor that a block has been verified.

Trait Implementations

impl<V: Clone + Variant, B: Clone + Block> Clone for Mailbox<V, B>

fn clone(&self) -> Mailbox<V, B>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<V: Variant, B: Block> Reporter for Mailbox<V, B>

type Activity = Activity<V, <B as Committable>::Commitment>

Activity is specified by the underlying consensus implementation and can be interpreted if desired.

async fn report(&mut self, activity: Self::Activity)

Report some activity observed by the consensus implementation.