From 05c4e2b5770133228daff7c262945f078a4e4456 Mon Sep 17 00:00:00 2001
From: Sam Anthony <sam@samanthony.xyz>
Date: Sat, 16 Nov 2024 14:28:13 -0500
Subject: ReliableMulticast.close()

---
 src/main/java/derms/net/ConcurrentMulticastSocket.java | 10 ++++++++++
 1 file changed, 10 insertions(+)

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

diff --git a/src/main/java/derms/net/ConcurrentMulticastSocket.java b/src/main/java/derms/net/ConcurrentMulticastSocket.java
index 24a040c..6aeb5a8 100644
--- a/src/main/java/derms/net/ConcurrentMulticastSocket.java
+++ b/src/main/java/derms/net/ConcurrentMulticastSocket.java
@@ -4,6 +4,8 @@ import java.io.IOException;
 import java.net.DatagramPacket;
 import java.net.InetAddress;
 import java.net.MulticastSocket;
+import java.net.SocketException;
+import java.time.Duration;
 
 public class ConcurrentMulticastSocket {
     private final MulticastSocket sock;
@@ -31,6 +33,14 @@ public class ConcurrentMulticastSocket {
         sock.receive(p);
     }
 
+    public synchronized void setSoTimeout(Duration timeout) throws SocketException {
+        sock.setSoTimeout((int) timeout.toMillis());
+    }
+
+    public synchronized void close() {
+        sock.close();
+    }
+
     @Override
     public String toString() {
         return sock.getLocalSocketAddress().toString();
-- 
cgit v1.2.3