From b3608b5f5f02678114500e77deb3bb9ef310d25d Mon Sep 17 00:00:00 2001
From: Sam Anthony <sam@samanthony.xyz>
Date: Fri, 22 Nov 2024 12:48:24 -0500
Subject: runicast: make constructors public

---
 src/main/java/derms/net/runicast/ReliableUnicastReceiver.java | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

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

diff --git a/src/main/java/derms/net/runicast/ReliableUnicastReceiver.java b/src/main/java/derms/net/runicast/ReliableUnicastReceiver.java
index dc69834..81e3502 100644
--- a/src/main/java/derms/net/runicast/ReliableUnicastReceiver.java
+++ b/src/main/java/derms/net/runicast/ReliableUnicastReceiver.java
@@ -10,6 +10,7 @@ import java.time.Duration;
 import java.util.concurrent.*;
 import java.util.logging.Logger;
 
+/** The receiving end of a reliable unicast connection. */
 public class ReliableUnicastReceiver<T extends MessagePayload> {
     private static final Duration soTimeout = Duration.ofMillis(500); // Socket timeout.
 
@@ -19,9 +20,11 @@ public class ReliableUnicastReceiver<T extends MessagePayload> {
     private final ExecutorService pool;
 
     /**
+     * Listen for incoming messages on the specified address and port.
+     *
      * @param laddr The local IP address and port to listen on.
      */
-    ReliableUnicastReceiver(SocketAddress laddr) throws IOException {
+    public ReliableUnicastReceiver(SocketAddress laddr) throws IOException {
         this.sock = new ConcurrentDatagramSocket(laddr);
         this.sock.setSoTimeout(soTimeout);
         this.delivered = new LinkedBlockingQueue<T>();
-- 
cgit v1.2.3