Struct EventSubscription 

pub struct EventSubscription<V> { /* private fields */ }

Application ownership of one running subscription.

Implementations

impl<V> EventSubscription<V>

pub fn id(&self) -> SubscriptionId

Opaque identity allocated by the pure client.

pub async fn recv(&mut self) -> Option<EventNotification<V>>

Receive one package value and release its bounded queue slot.

pub async fn next_state(&mut self) -> Option<StateChange>

Receive one lifecycle fact.

pub async fn next_event(&mut self) -> Option<EventSubscriptionEvent<V>>

Receive the next package value or lifecycle fact without favoring either channel.

This is the cancellation-safe choice for applications which must distinguish an initial refusal from the first package snapshot. Self::recv and Self::next_state remain available when an application intentionally observes only one side.

pub async fn unsubscribe(&self) -> Result<(), EventSubscriptionError>

Send Expires 0 and wait only for command admission. Terminal NOTIFY or Timer N completes the protocol operation and is observable through Self::next_state.

Trait Implementations

impl<V: Debug> Debug for EventSubscription<V>

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

Formats the value using the given formatter.

impl<V> Drop for EventSubscription<V>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.