astu 0.0.0

Astu library
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

use std::future::Future;
use std::time::Duration;

use anyhow::Context;
use anyhow::Result;

/// Spawns a future as a Tokio task and applies a timeout to it.
///
/// # Errors
///
/// - If the timeout is reached
/// - If the task fails to join
pub async fn spawn_timeout<T>(
    duration: Duration,
    future: impl Future<Output = T> + Send + 'static,
) -> Result<T>
where
    T: Send + 'static,
{
    let task = tokio::spawn(future);
    let timeout = tokio::time::timeout(duration, task);
    let t = timeout
        .await
        .context("tokio task timed out")?
        .context("tokio task failed to join")?;
    Ok(t)
}