Struct DatabaseChanges 

pub struct DatabaseChanges { /* private fields */ }

A live commit observation; coalesces changes and ends when the writer closes.

Implementations

impl DatabaseChanges

pub fn take_changed(&mut self) -> Result<bool, DbError>

Whether a relevant commit happened since the previous observation, without waiting; the first call reports the initial state.

pub fn changed(&self) -> impl Future<Output = ()> + Send + 'static

Resolves once a relevant commit happened since the previous observation, or the handle failed or closed. It owns its subscription, so a worker can wait on it beside other wakes; take_changed then consumes the change.

pub async fn next(&mut self) -> Result<(), DbError>

The initial state, then each relevant commit. No timer or polling is used.