Struct ConnectionConversation 

pub struct ConnectionConversation { /* private fields */ }

Library conversation resource owned by a single connection process.

Implementations

impl ConnectionConversation

pub fn new(resource: Box<dyn ConversationResource>) -> Self

Creates an owned conversation resource for one connection process.

pub fn participant_pids(&self) -> Vec<u64>

Returns the participant PIDs linked to the supervised conversation.

pub fn has_detected_crash(&self) -> bool

Returns true once a participant crash has been structurally detected through the linked-EXIT mechanism.

pub fn await_crash(&self, timeout: Duration) -> Option<Instant>

Blocks (event-driven) up to timeout for a structural crash signal.

pub fn receive_reply( &self, timeout: Duration, ) -> Result<MessageEnvelope, ServerError>

Receives the next participant reply for this conversation, bounded by timeout.

Errors

Returns ServerError when no reply arrives in time or the conversation is unavailable.

Trait Implementations

impl Debug for ConnectionConversation

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

Formats the value using the given formatter.