quincy 2.0.0-rc.3

QUIC-based VPN - Core library
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use futures::stream::FuturesUnordered;
use futures::StreamExt;
use tokio::task::JoinHandle;

use crate::error::Result;

/// Joins all tasks in a FuturesUnordered or aborts them after a specified duration.
pub async fn abort_all<R>(mut tasks: FuturesUnordered<JoinHandle<R>>) -> Result<()> {
    let mut aborted_tasks = tasks
        .iter_mut()
        .map(|handle| async {
            handle.abort();
            handle.await
        })
        .collect::<FuturesUnordered<_>>();

    while aborted_tasks.next().await.is_some() {}

    Ok(())
}