Struct RuntimeRealtimeProductTurnHandle 

pub struct RuntimeRealtimeProductTurnHandle { /* private fields */ }

Runtime-backed RealtimeProductTurnHandle impl.

Implementations

impl RuntimeRealtimeProductTurnHandle

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 RuntimeRealtimeProductTurnHandle

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

Formats the value using the given formatter.

impl RealtimeProductTurnHandle for RuntimeRealtimeProductTurnHandle

fn turn_in_flight(&self) -> Result<bool, DslTransitionError>

Fire ProductTurnInFlight. Returns Ok(true) when the turn advanced from Idle; Ok(false) when already in-flight.

fn turn_committed(&self) -> Result<bool, DslTransitionError>

Fire ProductTurnCommitted. Returns Ok(true) when the phase advanced (AwaitingProgress → Committed, or OutputStarted → Preemptible); Ok(false) otherwise.

fn output_started(&self) -> Result<bool, DslTransitionError>

Fire ProductOutputStarted. Returns Ok(true) when the phase advanced (AwaitingProgress → OutputStarted, or Committed → Preemptible); Ok(false) otherwise.

fn turn_interrupted(&self) -> Result<bool, DslTransitionError>

Fire ProductTurnInterrupted. Returns Ok(true) when the output-started milestone was cleared (Preemptible → Committed, or OutputStarted → AwaitingProgress); Ok(false) otherwise.

fn turn_terminal(&self) -> Result<bool, DslTransitionError>

Fire ProductTurnTerminal. Returns Ok(true) when the phase advanced back to Idle from any non-Idle phase; Ok(false) when already Idle.

fn current_phase(&self) -> RealtimeProductTurnPhase

Read the current typed phase from the DSL.

fn projection_advance_observed( &self, advanced_at_ms: u64, ) -> Result<bool, DslTransitionError>

Fire RealtimeProjectionAdvanceObserved { advanced_at_ms } — the shell received a SessionContextAdvanced observer tick. The DSL decides the resulting freshness based on the current product-turn phase (live → StaleDeferred; idle → StaleImmediate).

fn projection_refreshed( &self, observed_ms: u64, ) -> Result<bool, DslTransitionError>

Fire RealtimeProjectionRefreshed { observed_ms } — the shell completed a provider-session refresh drain. Returns to Clean.

fn projection_baseline_observed( &self, observed_ms: u64, ) -> Result<bool, DslTransitionError>

Fire RealtimeProjectionBaselineObserved { observed_ms } — the shell observed a provider-owned session-context mutation that the currently open provider session already contains. This may advance a clean frontier, but it must not clear StaleDeferred / StaleImmediate; only a real refresh drain may make stale state clean.

fn projection_reset(&self, baseline_ms: u64) -> Result<bool, DslTransitionError>

Fire RealtimeProjectionReset { baseline_ms } — the shell closed or reconnected the product session and wants to re-seed the Clean baseline at the current DSL session-context watermark.

fn projection_freshness(&self) -> RealtimeProjectionFreshness

Read the current typed projection-freshness discriminant from the DSL. The shell reads this at the canonical drain sites (observer tick arrival, input-chunk refresh gate, turn-end drain) to decide whether to rebuild the provider session’s projection.

fn projection_frontier_ms(&self) -> u64

Read the current monotonic frontier watermark from the DSL.

fn install_projection_freshness_observer( &self, observer: Arc<dyn RealtimeProjectionFreshnessObserver>, )

Install a typed observer for RealtimeProjectionFreshnessChanged effect emission. Implementations without an installed observer drop the effect (standalone / WASM paths).

fn install_projection_freshness_observer_with_snapshot( &self, observer: Arc<dyn RealtimeProjectionFreshnessObserver>, ) -> (RealtimeProjectionFreshness, u64)

Atomically install a typed observer and return the current freshness snapshot as a single authority read. Implementations MUST hold the same authority lock that projection transitions use for both observer installation and the (freshness, frontier) sample, so no RealtimeProjectionFreshnessChanged effect can slip between “observer visible” and “socket seeded from the DSL”.

fn classify_client_input_submitted(&self) -> Result<bool, DslTransitionError>

Fire ClassifyRealtimeClientInputSubmitted — the client’s input chunk was accepted by the provider session. Returns Ok(false) when already ReattachAndRecover.

fn classify_mid_turn_activity(&self) -> Result<bool, DslTransitionError>

Fire ClassifyRealtimeMidTurnActivity — the provider session emitted a non-terminal activity (e.g. a tool call) inside a live turn. Returns Ok(false) when already ReattachAndRecover.

fn classify_turn_terminated(&self) -> Result<bool, DslTransitionError>

Fire ClassifyRealtimeTurnTerminated — the current turn reached a logical terminal stop reason. Also folds in the pending StaleDeferred → StaleImmediate promotion so the turn-end drain site picks up any pending advance.

fn reconnect_policy_on_clean_close(&self) -> RealtimeReconnectPolicy

Read the typed reconnect-policy classification. The shell reads this at the clean-close branch to decide whether a clean provider- session close should trigger a proactive reattach (ReattachAndRecover) or close the channel cleanly (CleanExit).

fn is_in_flight(&self) -> bool

True iff the provider session has an active turn (any non-Idle phase). Used by the realtime-WS projection-refresh gate.

fn should_preempt_on_input(&self) -> bool

True iff an input chunk arriving now should preempt the current provider-managed turn — i.e. the turn has reached Preemptible.

fn is_projection_stale_immediate(&self) -> bool

Convenience accessor: true iff the current freshness is StaleImmediate — the shell uses this at drain sites.