use std::sync::mpsc;
use std::thread;
use std::time::Duration;
use color_eyre::eyre::{Context, Result};
pub fn run_with_timeout<F, T>(f: F, timeout: Duration) -> Result<T>
where
F: FnOnce() -> Result<T> + Send,
T: Send,
{
let (tx, rx) = mpsc::channel();
thread::scope(|s| {
s.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")
})?
}