2 files changed, 9 insertions, 3 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>();
diff --git a/src/main/java/derms/net/runicast/ReliableUnicastSender.java b/src/main/java/derms/net/runicast/ReliableUnicastSender.java
index ecfece4..83408d5 100644
--- a/src/main/java/derms/net/runicast/ReliableUnicastSender.java
+++ b/src/main/java/derms/net/runicast/ReliableUnicastSender.java
@@ -16,6 +16,7 @@ import java.util.concurrent.LinkedBlockingQueue;
 import java.util.concurrent.atomic.AtomicLong;
 import java.util.logging.Logger;
 
+/** The sending end of a reliable unicast connection. */
 public class ReliableUnicastSender<T extends MessagePayload> {
     private static final Duration soTimeout = Duration.ofMillis(500); // Socket timeout.
 
@@ -27,9 +28,11 @@ public class ReliableUnicastSender<T extends MessagePayload> {
     private final ExecutorService pool;
 
     /**
-     * @param raddr Remote IP address to connect to.
+     * Connect to the specified address and port.
+     *
+     * @param raddr The remote IP address to connect to.
      */
-    ReliableUnicastSender(InetSocketAddress raddr) throws IOException {
+    public ReliableUnicastSender(InetSocketAddress raddr) throws IOException {
         this.next = new AtomicLong(0);
         this.unacked = new AtomicLong(0);
         this.sent = new LinkedBlockingQueue<Message<T>>();