abpl 0.1.1

A collection of Rust boilerplate: a reloadable-systemd-service lifecycle helper, a hot-reloading axum wrapper, a serializable/typed error derive macro, and small utility newtypes.
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
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77

use std::{
	sync::mpsc::sync_channel,
	time::{Duration, Instant},
};

#[test]
pub fn primitive_sanity_check() {
	// This is just to confirm that `sync_channel(0)`  won't block if it's actively another thread is actively
	// waiting/listening.
	let (tx, rx) = sync_channel::<()>(0);
	std::thread::spawn(move || tx.send(()));
	std::thread::sleep(Duration::from_secs(1));
	assert_eq!(rx.try_recv(), Ok(()));

	let (tx, rx) = sync_channel::<()>(0);
	std::thread::spawn(move || {
		let _ = rx.recv();
	});
	std::thread::sleep(Duration::from_secs(1));
	assert_eq!(tx.try_send(()), Ok(()));
}

#[test]
fn cancel_wakes_sleep() {
	let (handle, sleeper) = super::cancelable_sleep();
	std::thread::spawn(move || {
		std::thread::sleep(Duration::from_millis(50));
		handle.cancel();
	});
	let start = Instant::now();
	sleeper.sleep(Duration::from_secs(10));
	assert!(start.elapsed() < Duration::from_secs(1));
}

#[test]
fn sleep_until_past_deadline_returns_immediately() {
	let (_handle, sleeper) = super::cancelable_sleep();
	let start = Instant::now();
	sleeper.sleep_until(start - Duration::from_secs(1));
	assert!(start.elapsed() < Duration::from_millis(100));
}

#[test]
fn cancel_before_sleep_is_still_observed() {
	// `cancel` only reports `false` on disconnect -- a rendezvous channel with no receiver
	// currently blocked in `recv` fails `try_send` with `Full`, not `Disconnected`, so this is
	// still a "true" (the `Sleeper` just hadn't started listening yet, that's not the same as
	// it being gone).
	let (handle, sleeper) = super::cancelable_sleep();
	assert!(handle.cancel());

	let start = Instant::now();
	sleeper.sleep(Duration::from_millis(50));
	assert!(start.elapsed() >= Duration::from_millis(50));
}

#[test]
fn cancel_returns_false_once_sleeper_is_dropped() {
	let (handle, sleeper) = super::cancelable_sleep();
	drop(sleeper);
	assert!(!handle.cancel());
}

#[test]
fn handle_is_clone() {
	let (handle, sleeper) = super::cancelable_sleep();
	let handle2 = handle.clone();
	std::thread::spawn(move || {
		std::thread::sleep(Duration::from_millis(50));
		handle2.cancel();
	});
	let start = Instant::now();
	sleeper.sleep(Duration::from_secs(10));
	assert!(start.elapsed() < Duration::from_secs(1));
	// The original handle is still usable after the clone fired.
	drop(handle);
}