fluvio-future 0.8.3

I/O futures for Fluvio project
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use std::time;

use anyhow::Result;

use crate::timer;

pub use futures_lite::future::*;

/// If the future completes before the duration has elapsed, then the completed value is returned.
/// Otherwise, an error is returned and the future is canceled.
pub async fn timeout<F, T>(duration: time::Duration, future: F) -> Result<T>
where
    F: Future<Output = T>,
    T: Send + 'static,
{
    race(async move { Ok(future.await) }, async move {
        let _ = timer::sleep(duration).await;
        Err(anyhow::anyhow!("Future timed out after {:?}", duration))
    })
    .await
}