atap 0.1.0

Threadsafe futureless async runtime for macOS
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

//! # Within
//! Running a task that answers with a `Result` to a time limit

use atap::{Runtime, RuntimeError, Task, builder::Standalone};
use std::time::Duration;

/// Spawns `task` limited to `limit` and waits for its answer
///
/// A task that runs out of time answers `Err(TimedOut)`, the same as
/// any other error it gives
pub fn within<F, T>(task: F, limit: Duration) -> Result<T, RuntimeError>
where
    F: Task<Output = Result<T, RuntimeError>>,
    F::Input: Standalone,
    T: Send + 'static,
{
    Runtime::task(task)
        .timeout(limit)
        .spawn()
        .take()
        .and_then(|answer| answer)
}