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 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.