Skip to main content

live_changes

Function live_changes 

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

Start a live changes stream that sends events through an mpsc channel.

Spawns a background task that polls the adapter for changes and sends each ChangeEvent through the returned receiver. The ChangesHandle controls the stream’s lifecycle.