1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

use color_eyre::eyre::{Context, Result};
use std::sync::mpsc;
use std::thread;
use std::time::Duration;

pub fn run_with_timeout<F, T>(f: F, timeout: Duration) -> Result<T>
where
    F: FnOnce() -> Result<T> + Send + 'static,
    T: Send + 'static,
{
    let (tx, rx) = mpsc::channel();
    thread::spawn(move || {
        let result = f();
        // If sending fails, the timeout has already been reached.
        let _ = tx.send(result);
    });
    rx.recv_timeout(timeout).context("timed out")?
}