beet_core 0.0.8

Core utilities and types for other beet crates
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

use super::performance_now;
use crate::prelude::*;
use std::time::Duration;

pub async fn poll_ok<T>(f: impl FnMut() -> Result<T>) -> Result<T> {
	poll_ok_with_timeout(f, Duration::from_secs(2)).await
}

pub async fn poll_ok_with_timeout<T>(
	mut f: impl FnMut() -> Result<T>,
	timeout: Duration,
) -> Result<T> {
	let start = performance_now();
	loop {
		match f() {
			Ok(val) => return Ok(val),
			Err(err) => {
				if performance_now() - start > timeout.as_millis() as f64 {
					return Err(err);
				}
				time_ext::sleep(Duration::from_millis(10)).await;
			}
		}
	}
}