Struct ConversationHandle 

pub struct ConversationHandle { /* private fields */ }

Cloneable handle for interacting with a conversation actor.

Implementations

impl ConversationHandle

pub fn send(&self, message: impl Into<Envelope>) -> Result<(), LiminalError>

Sends a message envelope to the conversation actor.

Errors

Returns a LiminalError when the actor cannot accept or process the message.

pub fn send_with_op_id( &self, message: impl Into<Envelope>, op_id: Option<u64>, ) -> Result<(), LiminalError>

Sends a message with the server’s in-process reply correlation marker. Some(op_id) routes a produced reply to the correlated server queue; None marks fire-and-forget traffic whose produced reply is discarded by the participant runner. The marker never enters an Envelope or the wire.

Errors

Returns a LiminalError when the actor cannot accept or process the message.

pub fn receive(&self) -> Result<Envelope, LiminalError>

Receives the next available envelope from the conversation actor.

Errors

Returns a LiminalError when the actor is closed, failed, or unavailable.

pub fn close(&self) -> Result<(), LiminalError>

Closes the conversation normally.

Errors

Returns a LiminalError when the actor cannot close normally.

pub fn query_state(&self) -> Result<ConversationState, LiminalError>

Queries the actor state for diagnostics.

Errors

Returns a LiminalError when the state cannot be queried.

pub fn actor_pid(&self) -> Result<ParticipantPid, LiminalError>

Returns the current actor PID.

Errors

Returns a LiminalError when the supervisor cannot inspect the actor.

Trait Implementations

impl Clone for ConversationHandle

fn clone(&self) -> ConversationHandle

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConversationHandle

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

Formats the value using the given formatter.