Struct Mailbox 

pub struct Mailbox<E, A>
where
    E: Rng + Spawner + Metrics + Clock,
    A: Application<E>,
{ /* private fields */ }

Channel-based proxy to the Stateful actor.

Implements the consensus application and verifying traits by forwarding each call to the actor via a message and awaiting the response.

Implementations

impl<E, A> Mailbox<E, A>

where E: Rng + Spawner + Metrics + Clock, A: Application<E>,

pub async fn subscribe_databases(&self) -> A::Databases

Wait for the attached database set.

This resolves once startup handoff has attached the database set to the serving actor. Late callers receive the current database set immediately.

Trait Implementations

impl<E, A> Application<E> for Mailbox<E, A>

where E: Rng + Spawner + Metrics + Clock, A: Application<E>,

type SigningScheme = <A as Application<E>>::SigningScheme

The signing scheme used by the application.

type Context = <A as Application<E>>::Context

Context is metadata provided by the consensus engine associated with a given payload.

type Block = <A as Application<E>>::Block

The block type produced by the application’s builder.

async fn propose( &mut self, context: (E, Self::Context), ancestry: impl Stream<Item = Self::Block> + Send + 'static, ) -> Option<Self::Block>

Build a new block on top of the provided parent ancestry. If the build job fails, or the proposer’s slot should be skipped, the implementor should return None.

async fn verify( &mut self, context: (E, Self::Context), ancestry: impl Stream<Item = Self::Block> + Send + 'static, ) -> bool

Verify a block produced by the application’s proposer, relative to its ancestry.

impl<E, A> Clone for Mailbox<E, A>

where E: Rng + Spawner + Metrics + Clock, A: Application<E>,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<E, A> Reporter for Mailbox<E, A>

where E: Rng + Spawner + Metrics + Clock, A: Application<E>,

type Activity = Update<<A as Application<E>>::Block>

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

fn report(&mut self, activity: Self::Activity) -> Feedback

Report some activity observed by the consensus implementation.