Struct FetchGaps 

pub struct FetchGaps(Box<FetchGapTracker>);

The Prior Group ID Gap and Prior Object ID Gap conditions of draft-15 Section 11.1 and draft-15 Section 11.2 that one fetch stream shows.

PriorGaps::from_properties refuses what one Object shows. Across the stream this refuses “A Group contains more than one Object with different values for Prior Group ID Gap” for the Objects of one Group, “An endpoint receives an Object with a Prior Group ID Gap covering an Object it previously received”, “An endpoint receives an Object with a Group ID within a previously communicated gap”, and the same two for Prior Object ID Gap, for the Group and the Object before on the stream. draft-15 Section 9.16.3: “Within each group, objects are sent in Object ID order; subgroup ID is not used for ordering.”

FetchObjectReader::read_object_header applies it to each Object it reads.

Tuple Fields

0: Box<FetchGapTracker>

Implementations

impl FetchGaps

pub fn new() -> Self

Track the Objects of one fetch stream.

pub fn check( &mut self, group_id: u64, object_id: u64, extension_block: &[u8], ) -> Result<PriorGaps, CodecError>

Check the next Object on the stream, from its resolved Group ID and Object ID and its extension block, refusing a gap condition with CodecError::MalformedTrack and a block that does not parse as crate::object_properties::parse_object_properties does. Records the Object only when it passes.

Trait Implementations

impl Clone for FetchGaps

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 FetchGaps

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

Formats the value using the given formatter.

impl Default for FetchGaps

fn default() -> Self

Returns the “default value” for a type.

impl Eq for FetchGaps

impl PartialEq for FetchGaps

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for FetchGaps