Struct InboundStream 

pub struct InboundStream {
    pub epoch: u16,
    pub baseline: Option<u8>,
    pub seen: SeenWindow,
    pub refs: RefRing,
    pub edit_refs: EditRing,
    pub pending: Vec<PendingRepair, 8>,
    pub sender_key: Option<PublicKey>,
    pub collided: bool,
    pub last_request_ms: u64,
    pub last_active_ms: u64,
}

Inbound stream state for one (conversation, sender) pair.

Fields

epoch: u16

Local epoch counter; bumped on reset so stale cached state can never merge across a reset.

baseline: Option<u8>

Most recent (serial-order) accepted ID.

seen: SeenWindow

refs: RefRing

edit_refs: EditRing

Edit IDs on this stream, mapped back to the originals they replaced.

pending: Vec<PendingRepair, 8>

sender_key: Option<PublicKey>

Resolved full key of a claimed multicast member, when known. Needed to address group repair requests.

collided: bool

Two known peer keys collide on this stream’s hint; automatic repair is suppressed and references resolve only when unambiguous.

last_request_ms: u64

last_active_ms: u64

Implementations

impl InboundStream

pub fn new(now_ms: u64) -> Self

pub fn reset_epoch(&mut self, new_baseline: Option<u8>)

Start a new epoch, discarding cached wire mappings and repair state but not transcript history.

pub fn cancel_pending(&mut self, message_id: u8, fragment: Option<u8>)

Cancel pending repairs satisfied by an arrival: a whole-message arrival (fragment == None) satisfies everything for that ID, while a fragment arrival satisfies its own request and any whole-message request (which fragment zero or reassembly tracking supersedes).

Trait Implementations

impl Clone for InboundStream

fn clone(&self) -> InboundStream

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InboundStream

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

Formats the value using the given formatter.