summaryrefslogtreecommitdiffstats
path: root/src/main/java/derms/net/runicast/ReliableUnicastReceiver.java
diff options
context:
space:
mode:
authorSam Anthony <sam@samanthony.xyz>2024-11-22 12:48:24 -0500
committerSam Anthony <sam@samanthony.xyz>2024-11-22 12:48:24 -0500
commitb3608b5f5f02678114500e77deb3bb9ef310d25d (patch)
tree8dc86edd697078dfb0da38711b3201fdc4b89456 /src/main/java/derms/net/runicast/ReliableUnicastReceiver.java
parent0912e30fb375f60bade22fd8cf7331e1b8d77659 (diff)
downloadsoen423-b3608b5f5f02678114500e77deb3bb9ef310d25d.zip
runicast: make constructors public
Diffstat (limited to 'src/main/java/derms/net/runicast/ReliableUnicastReceiver.java')
-rw-r--r--src/main/java/derms/net/runicast/ReliableUnicastReceiver.java5
1 files changed, 4 insertions, 1 deletions
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>();