rivet-envoy-client 2.3.1

Envoy client transport for Rivet actor hosts
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
25
26
27
28
29

use std::time::Duration;

use tokio::sync::mpsc;

use crate::utils::sleep;

/// Debug-only wrapper around an `mpsc::UnboundedReceiver` that injects configurable
/// latency on each receive. Used for testing reconnection behavior under latency.
pub struct LatencyReceiver<T> {
	rx: mpsc::UnboundedReceiver<T>,
	latency: Option<Duration>,
}

impl<T> LatencyReceiver<T> {
	pub fn new(rx: mpsc::UnboundedReceiver<T>, latency_ms: Option<u64>) -> Self {
		Self {
			rx,
			latency: latency_ms.filter(|&ms| ms > 0).map(Duration::from_millis),
		}
	}

	pub async fn recv(&mut self) -> Option<T> {
		let item = self.rx.recv().await?;
		if let Some(latency) = self.latency {
			sleep(latency).await;
		}
		Some(item)
	}
}