sqlx-core 0.9.0-alpha.1

Core of SQLx, the rust SQL toolkit. Not intended to be used directly.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use std::{future::Future, pin::pin, time::Duration};

use futures_util::future::{select, Either};

use crate::rt::TimeoutError;

pub async fn sleep(duration: Duration) {
    timeout_future(duration).await;
}

pub async fn timeout<F: Future>(duration: Duration, future: F) -> Result<F::Output, TimeoutError> {
    match select(pin!(future), timeout_future(duration)).await {
        Either::Left((result, _)) => Ok(result),
        Either::Right(_) => Err(TimeoutError),
    }
}

fn timeout_future(duration: Duration) -> impl Future {
    async_io::Timer::after(duration)
}