pub(crate) async fn capture_packets( client: DiagClient, streams: Vec<impl Future<Output = Result<u64, Error>>>, capture_duration: Duration, )