Struct OperationalEventStreamHealthSubscription 

pub struct OperationalEventStreamHealthSubscription { /* private fields */ }

Task-free subscription to sticky authoritative-stream health.

Self::current exposes the initial state immediately. Self::changed waits for either a published health transition or loss of the operational event receiver. Receiver loss is converted to the same sticky Degraded state inline, so subscribing does not create an idle background task that could outlive core lifecycle drain.

Implementations

impl OperationalEventStreamHealthSubscription

pub fn current(&self) -> OperationalEventStreamHealth

Return current sticky health without waiting.

pub async fn changed(&mut self) -> OperationalEventStreamHealth

Wait for degradation and return the new sticky state.

Degraded is terminal for this process-local stream. Calling this method after observing it therefore returns Degraded immediately; correctness consumers should stop accepting work at that point.

Trait Implementations

impl Clone for OperationalEventStreamHealthSubscription

fn clone(&self) -> OperationalEventStreamHealthSubscription

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.