Function drain_data_events 

pub async fn drain_data_events(
    rx: &mut UnboundedReceiver<DataEvent>,
    timeout: Duration,
) -> Vec<DataEvent>

Collects the data events received on rx within timeout.

While the live runner’s thread-local sender keeps the channel open, this waits out the full window and suits absence checks. Prefer collect_data_events_until_response whenever the events end with a correlated response.