Struct Subscription 

pub struct Subscription { /* private fields */ }

Register before reading the baseline. Dirties arriving during that read stay queued. Drop requests cancellation; await Self::close before removing the subscribed state.

Implementations

impl Subscription

pub async fn new(state: &Path) -> Self

pub async fn close(self) -> Result<(), String>

Stop this subscription and wait for its connection, hub and probe database to close. Other subscriptions remain independent. Dropping this future still requests cancellation.

pub async fn next_reconciled(&mut self) -> Change

Process-owner death has no database writer; reuse the subscription’s reconciliation cadence when an observer also owns liveness reconciliation.

pub async fn next(&mut self) -> Change

pub async fn next_state(&mut self) -> Change

Schedulers and non-session UIs can ignore session-only hints without reloading state.

Trait Implementations

impl Drop for Subscription

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.