Struct RequestTracker 

pub(super) struct RequestTracker {
    next_request_counter: u64,
    next_timeout_timer_id: RequestTimeoutId,
    pending_requests: Vec<PendingRequestState>,
}

Owns recording request identities, timeout identities and resolve-once state.

Fields

next_request_counter: u64

next_timeout_timer_id: RequestTimeoutId

pending_requests: Vec<PendingRequestState>

Implementations

impl RequestTracker

pub(super) const fn new() -> Self

pub(super) fn try_begin( &mut self, kind: PendingRequestKind, ) -> Option<PendingRequestStart>

pub(super) fn resolve_response( &mut self, response_to: &RequestId, expected_kind: PendingRequestKind, ok: bool, ) -> Vec<Command>

pub(super) fn resolve_timeout( &mut self, timeout_id: RequestTimeoutId, ) -> Option<Vec<Command>>

pub(super) fn clear(&mut self)

pub(super) fn fail_all(&mut self) -> Vec<Command>

Completes pending requests in begin order.

fn allocate_request_id(&mut self) -> RequestId

fn allocate_timeout_timer_id(&mut self) -> RequestTimeoutId

Trait Implementations

impl Clone for RequestTracker

fn clone(&self) -> RequestTracker

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RequestTracker

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for RequestTracker

fn default() -> Self

Returns the “default value” for a type.

impl PartialEq for RequestTracker

fn eq(&self, other: &RequestTracker) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for RequestTracker

impl StructuralPartialEq for RequestTracker