Struct Mailbox 

pub struct Mailbox<K: Span, P: Eq, S: Eq = ()> { /* private fields */ }

A way to send messages to the peer actor.

Trait Implementations

impl<K: Clone + Span, P: Clone + Eq, S: Clone + Eq> Clone for Mailbox<K, P, S>

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<K, P, S> Resolver for Mailbox<K, P, S>

where K: Span, P: PublicKey, S: Clone + Eq + Send + 'static,

fn fetch<D>(&mut self, key: D) -> Feedback

where D: Into<Fetch<Self::Key, Self::Subscriber>> + Send,

Send a fetch 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.

fn fetch_all<D>(&mut self, keys: Vec<D>) -> Feedback

where D: Into<Fetch<Self::Key, Self::Subscriber>> + Send,

Send fetches 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.

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

Send a retain request to the peer actor.

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

type Key = K

Type used to key data requested from peers.

type Subscriber = S

Type used to track subscribers on fetch keys.

impl<K, P, S> TargetedResolver for Mailbox<K, P, S>

where K: Span, P: PublicKey, S: Clone + Eq + Send + 'static,

fn fetch_targeted( &mut self, key: impl Into<Fetch<Self::Key, Self::Subscriber>> + Send, targets: NonEmptyVec<Self::PublicKey>, ) -> Feedback

Send a targeted fetch to the peer actor.

If a fetch is already in progress for this key:

• If the existing fetch has targets, the new targets are added to the set.
• If the existing fetch has no targets, it remains unrestricted.

To clear targeting and fall back to any peer, call fetch.

Targets are automatically cleared when the fetch succeeds or is canceled. When a peer is blocked for invalid data, only that peer is removed from the target set.

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

fn fetch_all_targeted<D>( &mut self, keys: Vec<(D, NonEmptyVec<Self::PublicKey>)>, ) -> Feedback

where D: Into<Fetch<Self::Key, Self::Subscriber>> + Send,

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

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

type PublicKey = P

Type used to identify peers for targeted fetch hints.