Struct Mailbox 

pub struct Mailbox<K, P> { /* private fields */ }

A way to send messages to the peer actor.

Trait Implementations

impl<K: Clone, P: Clone> Clone for Mailbox<K, P>

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<K: Span, P: PublicKey> Resolver for Mailbox<K, P>

async fn fetch(&mut self, key: Self::Key)

Send a fetch request to the peer actor.

If a fetch is already in progress for this key, this clears any existing targets for that key (the fetch will try any available peer).

If the engine has shut down, this is a no-op.

async fn fetch_all(&mut self, keys: Vec<Self::Key>)

Send a fetch request to the peer actor for a batch of keys.

If a fetch is already in progress for any key, this clears any existing targets for that key (the fetch will try any available peer).

If the engine has shut down, this is a no-op.

async fn fetch_targeted( &mut self, key: Self::Key, targets: NonEmptyVec<Self::PublicKey>, )

Send a targeted fetch request to the peer actor.

If the engine has shut down, this is a no-op.

async fn fetch_all_targeted( &mut self, requests: Vec<(Self::Key, NonEmptyVec<Self::PublicKey>)>, )

Send targeted fetch requests to the peer actor for a batch of keys.

If the engine has shut down, this is a no-op.

async fn cancel(&mut self, key: Self::Key)

Send a cancel request to the peer actor.

If the engine has shut down, this is a no-op.

async fn retain( &mut self, predicate: impl Fn(&Self::Key) -> bool + Send + 'static, )

Send a retain request to the peer actor.

If the engine has shut down, this is a no-op.

async fn clear(&mut self)

Send a clear request to the peer actor.

If the engine has shut down, this is a no-op.

type Key = K

Type used to uniquely identify data.

type PublicKey = P

Type used to identify peers for targeted fetches.