From f02bf05c7b639f5edb86388c96dbb209a4622be9 Mon Sep 17 00:00:00 2001
From: Sam Anthony <sam@samanthony.xyz>
Date: Fri, 15 Nov 2024 13:23:06 -0500
Subject: reliable multicast: prune received list

---
 src/main/java/derms/net/rmulticast/Wait.java | 15 +++++++++++++++
 1 file changed, 15 insertions(+)
 create mode 100644 src/main/java/derms/net/rmulticast/Wait.java

(limited to 'src/main/java/derms/net/rmulticast/Wait.java')

diff --git a/src/main/java/derms/net/rmulticast/Wait.java b/src/main/java/derms/net/rmulticast/Wait.java
new file mode 100644
index 0000000..f1180ed
--- /dev/null
+++ b/src/main/java/derms/net/rmulticast/Wait.java
@@ -0,0 +1,15 @@
+package derms.net.rmulticast;
+
+import java.time.Duration;
+import java.time.Instant;
+
+class Wait {
+    static void forDuration(Duration dur) throws InterruptedException {
+        Instant start = Instant.now();
+        Duration elapsed;
+        do {
+            Thread.yield();
+            elapsed = Duration.between(start, Instant.now());
+        } while (elapsed.compareTo(dur) < 0);
+    }
+}
-- 
cgit v1.2.3