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.