Struct BlobStreamOutEntry

pub struct BlobStreamOutEntry {
    pub last_sent_at: Option<Instant>,
    pub index: usize,
    pub is_received_by_remote: bool,
}

Represents an individual chunk of the blob data being streamed out. Each BlobStreamOutEntry holds metadata about a chunk, including:

• timer: The time when the chunk was last sent, or None if it has not been sent.
• index: The index of the chunk.
• start and end: Byte ranges representing the chunk’s position within the full blob.

Fields

last_sent_at: Option<Instant>

index: usize

is_received_by_remote: bool

Implementations

impl BlobStreamOutEntry

pub fn new(index: usize) -> Self

Creates a new BlobStreamOutEntry.

Arguments

• index - The index of the chunk.

Returns

A new BlobStreamOutEntry with a None timer.

pub fn sent_at_time(&mut self, time: Instant)

Updates the timer to the specified Instant, marking the time this entry was last sent.

Arguments

• time - The Instant at which the entry is being sent.

Trait Implementations

impl Clone for BlobStreamOutEntry

fn clone(&self) -> BlobStreamOutEntry

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for BlobStreamOutEntry

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

Formats the value using the given formatter.

impl PartialEq for BlobStreamOutEntry

fn eq(&self, other: &BlobStreamOutEntry) -> 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 BlobStreamOutEntry

impl StructuralPartialEq for BlobStreamOutEntry