Function collect_events_until_idle 

pub async fn collect_events_until_idle(
    rx: &mut Receiver<LiveEvent>,
    idle: Duration,
    max: Duration,
) -> Vec<LiveEvent>

Collect LiveEvents until the stream stays idle for idle (or max elapses). Useful for settling an as-fast-as-possible replay where “done” means “no more effects are propagating”.