Skip to main content

live_changes_events

Function live_changes_events 

Source
pub fn live_changes_events(
    adapter: Arc<dyn Adapter>,
    opts: ChangesStreamOptions,
) -> (Receiver<ChangesEvent>, ChangesHandle)
Expand description

Start a live changes stream that emits lifecycle events.

Like live_changes() but wraps each event in a ChangesEvent enum that includes Active, Paused, Complete, and Error lifecycle events alongside the actual Change events.