Struct ParticipantConnectionConversations 

pub struct ParticipantConnectionConversations { /* private fields */ }

Connection-local semantic-conversation dispatch map (contract R-D1: the connection’s binding/interest/dispatch maps are bounded by the signed max_semantic_conversations_per_connection).

One value lives in each connection process’s state for the connection’s lifetime and is dropped with it. A conversation enters the map exactly when a semantic operation for it COMMITS on this connection (the crate’s ConnectionConversationCapacityCommit::newly_tracked verdict) or when an observer-recovery batch arms its refusal-only recipient; refusals and replays leave the map untouched, exactly as the crate’s stage-6 selector leaves its counter unchanged. Growth is therefore bounded by the signed limit the stage-6 selector enforces.

Implementations

impl ParticipantConnectionConversations

pub fn tracking( &self, conversation_id: ConversationId, ) -> ConnectionConversationTracking

Stage-6 tracking fact for one conversation on this connection.

pub fn occupied(&self) -> u64

Current connection-conversation occupancy.

pub fn track(&mut self, conversation_id: ConversationId)

Installs one conversation slot after a capacity-committing operation.

pub fn tracked_conversations(&self) -> Vec<ConversationId>

Sorted tracked conversations (the observer-recovery preflight’s current-occupancy input).

Trait Implementations

impl Debug for ParticipantConnectionConversations

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

Formats the value using the given formatter.

impl Default for ParticipantConnectionConversations

fn default() -> ParticipantConnectionConversations

Returns the “default value” for a type.