reifydb-testing 0.4.11

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
24

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

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

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_millis(500) {
			panic!("failed to connect within 500ms")
		}
	}
	socket_addr.take().unwrap()
}