Struct BulkReceiveState 

pub struct BulkReceiveState { /* private fields */ }

Receiver-side exact-offset and replenishment state for one flow.

Implementations

impl BulkReceiveState

pub fn new( kind: BulkKind, flow: BulkFlow, max_record_payload: u32, credit_limit: u64, window: u64, ) -> Result<Self, BulkStateError>

Create one receiver flow and its initial absolute grant.

pub fn next_expected_offset(&self) -> u64

Return the next exact record offset.

pub fn credit_limit(&self) -> u64

Return the current absolute receive credit limit.

pub fn accept_record( &mut self, record: &BulkRecord, ) -> Result<u64, BulkStateError>

Validate and admit a record before its destination consumes the payload.

pub fn consume( &mut self, consumed_offset: u64, ) -> Result<Option<BulkCredit>, BulkStateError>

Mark admitted bytes consumed and return a replenishment when half the window remains.

pub fn accept_finish( &mut self, finish: BulkFinish, ) -> Result<(), BulkStateError>

Accept an exact finish after all earlier records.

Trait Implementations

impl Clone for BulkReceiveState

fn clone(&self) -> BulkReceiveState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BulkReceiveState

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

Formats the value using the given formatter.