util.rs

 1use std::time::Duration;
 2
 3use futures::Future;
 4use smol::future::FutureExt;
 5pub use util::*;
 6
 7pub async fn timeout<F, T>(timeout: Duration, f: F) -> Result<T, ()>
 8where
 9    F: Future<Output = T>,
10{
11    let timer = async {
12        smol::Timer::after(timeout).await;
13        Err(())
14    };
15    let future = async move { Ok(f.await) };
16    timer.race(future).await
17}
18
19#[cfg(any(test, feature = "test-support"))]
20pub struct CwdBacktrace<'a>(pub &'a backtrace::Backtrace);
21
22#[cfg(any(test, feature = "test-support"))]
23impl<'a> std::fmt::Debug for CwdBacktrace<'a> {
24    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
25        use backtrace::{BacktraceFmt, BytesOrWideString};
26
27        let cwd = std::env::current_dir().unwrap();
28        let cwd = cwd.parent().unwrap();
29        let mut print_path = |fmt: &mut std::fmt::Formatter<'_>, path: BytesOrWideString<'_>| {
30            std::fmt::Display::fmt(&path, fmt)
31        };
32        let mut fmt = BacktraceFmt::new(f, backtrace::PrintFmt::Full, &mut print_path);
33        for frame in self.0.frames() {
34            let mut formatted_frame = fmt.frame();
35            if frame
36                .symbols()
37                .iter()
38                .any(|s| s.filename().map_or(false, |f| f.starts_with(&cwd)))
39            {
40                formatted_frame.backtrace_frame(frame)?;
41            }
42        }
43        fmt.finish()
44    }
45}