Struct RuntimeCommsDrainHandle 

pub struct RuntimeCommsDrainHandle { /* private fields */ }

Runtime-backed CommsDrainHandle impl.

Routes every trait method to the corresponding DSL input / signal on a dedicated per-session MeerkatMachine DSL authority.

Implementations

impl RuntimeCommsDrainHandle

pub fn new(dsl: Arc<HandleDslAuthority>) -> Self

Construct a handle backed by the session’s shared DSL authority.

pub fn ephemeral() -> Self

Construct a handle backed by an ephemeral DSL authority.

See [RuntimeTurnStateHandle::ephemeral].

Trait Implementations

impl CommsDrainHandle for RuntimeCommsDrainHandle

fn ensure_drain_running(&self) -> Result<(), DslTransitionError>

Fire the EnsureDrainRunning signal — lazy spawn path.

fn spawn_drain(&self, mode: DrainMode) -> Result<(), DslTransitionError>

Fire the SpawnDrain { mode } input — explicit spawn with typed mode.

fn stop_drain(&self) -> Result<(), DslTransitionError>

Fire the StopDrain input.

fn drain_exited_clean(&self) -> Result<(), DslTransitionError>

Fire the DrainExitedClean input (drain stopped without failure).

fn drain_exited_respawnable(&self) -> Result<(), DslTransitionError>

Fire the DrainExitedRespawnable input (drain exited and can be respawned).

fn notify_drain_exited( &self, reason: DrainExitReason, ) -> Result<(), DslTransitionError>

Fire the NotifyDrainExited { reason } input with a typed reason.

impl Debug for RuntimeCommsDrainHandle

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

Formats the value using the given formatter.