Struct PendingRequests 

pub struct PendingRequests { /* private fields */ }

Pending request tracker for correlated request-response.

Implementations

impl PendingRequests

pub fn new() -> Self

Create a new empty tracker.

pub fn set_chain_manager(&mut self, cm: Arc<ChainManager>)

Attach a chain manager for exochain audit logging.

pub fn register(&mut self, request: MeshRequest)

Register a pending request.

pub fn try_complete( &mut self, response: &MeshIpcEnvelope, ) -> Option<MeshRequest>

Try to match a response to a pending request, removing it on match.

pub fn evict_timed_out(&mut self) -> Vec<String>

Remove timed-out requests. Returns their correlation IDs.

pub fn len(&self) -> usize

Number of pending requests.

pub fn is_empty(&self) -> bool

Whether there are no pending requests.

Trait Implementations

impl Default for PendingRequests

fn default() -> Self

Returns the “default value” for a type.