Struct FetchGapTracker 

pub(crate) struct FetchGapTracker {
    rules: GapRules,
    run: Option<GroupRun>,
    earlier: Option<(u64, u64)>,
}

The Prior gap state of one fetch stream.

Fields

rules: GapRules

run: Option<GroupRun>

earlier: Option<(u64, u64)>

The Group before the current one, and the gap it communicated.

Implementations

impl FetchGapTracker

pub(crate) fn new(rules: GapRules) -> Self

pub(crate) fn check( &mut self, group_id: u64, object_id: u64, group_gaps: &[u64], object_gap: Option<u64>, ) -> Result<(), CodecError>

Check the next Object, whose gaps its draft’s PriorGaps has already held to its Group ID and Object ID. Records the Object only when it passes.

Trait Implementations

impl Clone for FetchGapTracker

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FetchGapTracker

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

Formats the value using the given formatter.

impl Eq for FetchGapTracker

impl PartialEq for FetchGapTracker

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for FetchGapTracker