Struct RuntimeInteractionStreamHandle 

pub struct RuntimeInteractionStreamHandle { /* private fields */ }

Runtime-backed InteractionStreamHandle impl.

Every trait method routes to the corresponding DSL input on the session’s shared MeerkatMachine authority. After the transition lands, emitted effects are scanned for InteractionStreamCleanup and dispatched to the installed InteractionStreamCleanupObserver (if any), closing the “terminal transition → effect → shell projection cleanup” loop.

The observer is held as a Weak reference because the canonical owner is the session’s CommsRuntime, which in turn holds a strong handle pointer; storing the observer strongly would create a cycle preventing CommsRuntime::drop from firing on session teardown. Weak::upgrade returning None after teardown makes cleanup dispatch a no-op, which is the desired post-shutdown semantics.

Implementations

impl RuntimeInteractionStreamHandle

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 for tests and minimal hosts that explicitly opt into machine-owned semantics.

Trait Implementations

impl Debug for RuntimeInteractionStreamHandle

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

Formats the value using the given formatter.

impl InteractionStreamHandle for RuntimeInteractionStreamHandle

fn reserved(&self, corr_id: PeerCorrelationId) -> Result<(), DslTransitionError>

Fire InteractionStreamReserved { corr_id }.

fn attached(&self, corr_id: PeerCorrelationId) -> Result<(), DslTransitionError>

Fire InteractionStreamAttached { corr_id }.

fn completed( &self, corr_id: PeerCorrelationId, ) -> Result<(), DslTransitionError>

Fire InteractionStreamCompleted { corr_id }.

fn expired(&self, corr_id: PeerCorrelationId) -> Result<(), DslTransitionError>

Fire InteractionStreamExpired { corr_id }.

fn closed_early( &self, corr_id: PeerCorrelationId, ) -> Result<(), DslTransitionError>

Fire InteractionStreamClosedEarly { corr_id }.

fn state( &self, corr_id: PeerCorrelationId, ) -> Option<CoreInteractionStreamState>

Read the DSL-owned state for a given correlation id, if any.

fn install_cleanup_observer( &self, observer: Arc<dyn InteractionStreamCleanupObserver>, )

Install a projection-cleanup observer for the interaction stream lifecycle. The runtime handle invokes the observer whenever a DSL transition emits InteractionStreamCleanup, closing the loop “terminal transition → effect → shell projection cleanup”.