Struct RuntimePeerInteractionHandle 

pub struct RuntimePeerInteractionHandle { /* private fields */ }

Runtime-backed PeerInteractionHandle 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 PeerInteractionCleanup and dispatched to the installed PeerInteractionCleanupObserver (if any) — closing the “terminal transition → effect → shell projection cleanup” loop.

The cleanup observer is held as a Weak reference. In production the observer is the session’s CommsRuntime, which in turn holds a strong Arc<dyn PeerInteractionHandle> to this struct; storing the observer strongly would create a cycle that prevents CommsRuntime::drop from firing on session teardown (dropped listeners, leaked session-identity claims, zombie InprocRegistry entries). Weak breaks the cycle — once the runtime drops, upgrade() returns None and subsequent effect dispatches become no-ops, which is the desired semantics post-teardown.

Implementations

impl RuntimePeerInteractionHandle

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 (tests / legacy recovery paths).

Trait Implementations

impl Debug for RuntimePeerInteractionHandle

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

Formats the value using the given formatter.

impl PeerInteractionHandle for RuntimePeerInteractionHandle

fn request_sent( &self, corr_id: PeerCorrelationId, to: String, ) -> Result<(), DslTransitionError>

Fire PeerRequestSent { corr_id, to }.

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

Fire PeerResponseProgressArrived { corr_id }.

fn response_terminal( &self, corr_id: PeerCorrelationId, disposition: CorePeerDisposition, ) -> Result<(), DslTransitionError>

Fire PeerResponseTerminalArrived { corr_id, disposition }.

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

Fire PeerRequestTimedOut { corr_id }.

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

Fire PeerRequestReceived { corr_id } (inbound).

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

Fire PeerResponseReplied { corr_id } (inbound reply sent).

fn outbound_state( &self, corr_id: PeerCorrelationId, ) -> Option<CoreOutboundState>

Observe the DSL-owned state of an outbound peer request.

fn inbound_state(&self, corr_id: PeerCorrelationId) -> Option<CoreInboundState>

Observe the DSL-owned state of an inbound peer request.

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

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