Struct ConversationSupervisor 

pub struct ConversationSupervisor { /* private fields */ }

Implementations

impl ConversationSupervisor

pub fn new() -> Result<Self, LiminalError>

Errors

Returns LiminalError when the beamr scheduler cannot start.

pub fn spawn( &self, config: ConversationConfig, ) -> Result<ConversationActor, LiminalError>

Spawns one supervised conversation actor over the given participant pids.

The participants are linked for crash detection but are NOT forwarded requests (they are inert from the conversation’s perspective). Use ConversationSupervisor::spawn_with_participant to attach a real participant that processes forwarded messages.

Errors

Returns LiminalError when spawn, boot, or participant linking fails.

pub fn spawn_with_participant( &self, behaviour: Arc<dyn ParticipantBehaviour>, timeout: Option<Duration>, mode: ChannelMode, on_crash: CrashPolicy, ) -> Result<(ConversationActor, ParticipantPid), LiminalError>

Spawns a real participant native process running behaviour, then a supervised conversation actor linked to it. Requests sent through the returned actor’s handle are FORWARDED to the participant process, which genuinely processes them and delivers any reply back into the conversation — the request-reply path from LIM-005.

Returns the actor and the spawned participant’s pid (for crash injection and linkage assertions).

Errors

Returns LiminalError when participant spawn, actor spawn, boot, or linking fails.

pub fn scheduler(&self) -> Arc<Scheduler>

Returns the scheduler used by this supervisor.

pub fn registered_actor_count(&self) -> usize

Number of actor registrations currently held by this supervisor’s runtime. Lifecycle observability for the leak/churn gates: every closed or torn-down conversation must have removed its entry, so this count is pinned bounded across open/close cycles.

pub fn registered_participant_count(&self) -> usize

Number of participant registrations currently held by this supervisor’s runtime. Same lifecycle-gate role as Self::registered_actor_count.

pub fn shutdown(&self)

Stops the underlying scheduler.

Trait Implementations

impl Clone for ConversationSupervisor

fn clone(&self) -> ConversationSupervisor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConversationSupervisor

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

Formats the value using the given formatter.