Struct PendingRequests 

pub struct PendingRequests<K: Eq + Hash, R> { /* private fields */ }

A registry of in-flight requests awaiting responses, keyed by K.

Cloning is cheap and shares all state: register a request on one clone and deliver its response from another. This is the expected way to use the registry across tasks (e.g. a reader task calling handle_response while many sender tasks await their ResponseWaiters).

Implementations

impl<K: Eq + Hash + Clone, R> PendingRequests<K, R>

pub fn new() -> Self

Create a registry with the default 6s timeout.

pub fn set_timeout(&self, timeout: Duration)

Set the default timeout applied to requests registered after this call. Takes &self, so it works through a shared/cloned handle. Already-registered requests keep the timeout they were created with.

pub fn timeout(&self) -> Duration

The current default timeout.

pub fn len(&self) -> usize

Number of requests currently awaiting a response.

pub fn is_empty(&self) -> bool

Whether there are no requests currently awaiting a response.

pub fn contains(&self, key: &K) -> bool

Whether a request is currently pending for key.

pub fn prepare_response(&self, key: K) -> Result<ResponseWaiter<K, R>, Error>

Register a request under key, using the registry’s default timeout.

Returns Error::KeyAlreadyExists if a request with key is already pending.

pub fn prepare_response_with_timeout( &self, key: K, timeout: Duration, ) -> Result<ResponseWaiter<K, R>, Error>

Register a request under key with an explicit timeout.

pub fn handle_response(&self, key: K, response: R) -> Result<(), Error>

Deliver response to the request registered under key.

Returns Error::KeyNotFound if no request is pending for key, or Error::ReceiverDropped if the waiter was already dropped.

pub fn cancel(&self, key: &K) -> Result<(), Error>

Cancel the request registered under key, causing its waiter to resolve with Error::Canceled.

Returns Error::KeyNotFound if no request is pending for key.

pub fn cancel_all(&self) -> usize

Cancel every pending request, resolving all their waiters with Error::Canceled. Returns the number of requests canceled.

Useful when a connection drops and all in-flight requests should fail at once.

Trait Implementations

impl<K: Eq + Hash, R> Clone for PendingRequests<K, R>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<K: Eq + Hash, R> Default for PendingRequests<K, R>

fn default() -> Self

Returns the “default value” for a type.