reifydb-testing 0.7.0

Testing utilities and helpers for ReifyDB
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

// SPDX-License-Identifier: Apache-2.0
// Copyright (c) 2026 ReifyDB

use std::{net::SocketAddr, time::Instant};

use reifydb_value::value::duration::Duration;

pub fn busy_wait(f: impl Fn() -> Option<SocketAddr>) -> SocketAddr {
	let mut socket_addr: Option<SocketAddr>;
	#[allow(clippy::disallowed_methods)]
	let start = Instant::now();
	loop {
		socket_addr = f();
		if socket_addr.is_some() {
			break;
		}

		if start.elapsed() > Duration::from_milliseconds(500).unwrap().to_std() {
			panic!("failed to connect within 500ms")
		}
	}
	socket_addr.take().unwrap()
}