pub struct RuntimeSessionContextHandle { /* private fields */ }Expand description
Runtime-backed SessionContextHandle impl.
Mirrors the pattern used by super::RuntimePeerInteractionHandle:
the observer is held as a Weak so this handle does not keep the
realtime projection consumer alive past its socket’s lifetime.
Implementations§
Trait Implementations§
Source§impl Debug for RuntimeSessionContextHandle
impl Debug for RuntimeSessionContextHandle
Source§impl SessionContextHandle for RuntimeSessionContextHandle
impl SessionContextHandle for RuntimeSessionContextHandle
Source§fn context_advanced(
&self,
updated_at_ms: u64,
) -> Result<bool, DslTransitionError>
fn context_advanced( &self, updated_at_ms: u64, ) -> Result<bool, DslTransitionError>
Fire
AdvanceSessionContext { updated_at_ms }. Read moreSource§fn current_watermark_ms(&self) -> u64
fn current_watermark_ms(&self) -> u64
The monotonic watermark in milliseconds of the last successful
AdvanceSessionContext transition recorded on this handle. Read moreSource§fn install_observer(&self, observer: Arc<dyn SessionContextAdvancedObserver>)
fn install_observer(&self, observer: Arc<dyn SessionContextAdvancedObserver>)
Install a typed observer for
SessionContextAdvanced effect
emission. Implementations without an installed observer drop the
effect on the floor (standalone / WASM paths).Source§fn install_observer_with_baseline(
&self,
observer: Arc<dyn SessionContextAdvancedObserver>,
) -> u64
fn install_observer_with_baseline( &self, observer: Arc<dyn SessionContextAdvancedObserver>, ) -> u64
Atomically install a typed observer and return the current watermark
as a single critical section. Implementations MUST hold the same
authority lock that
context_advanced uses for both the watermark
read and the observer installation, so no SessionContextAdvanced
effect can slip between “sampled baseline” and “observer visible”. Read moreAuto Trait Implementations§
impl !Freeze for RuntimeSessionContextHandle
impl RefUnwindSafe for RuntimeSessionContextHandle
impl Send for RuntimeSessionContextHandle
impl Sync for RuntimeSessionContextHandle
impl Unpin for RuntimeSessionContextHandle
impl UnsafeUnpin for RuntimeSessionContextHandle
impl UnwindSafe for RuntimeSessionContextHandle
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more