2 files changed, 0 insertions, 50 deletions
diff --git a/src/main/java/derms/net/ConcurrentMulticastSocket.java b/src/main/java/derms/net/ConcurrentMulticastSocket.java
deleted file mode 100644
index 6aeb5a8..0000000
--- a/src/main/java/derms/net/ConcurrentMulticastSocket.java
+++ /dev/null
@@ -1,48 +0,0 @@
-package derms.net;
-
-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;
-
-    /** Create a socket for sending. */
-    public ConcurrentMulticastSocket() throws IOException {
-        this.sock = new MulticastSocket();
-    }
-
-    /** Create a socket bound to the specified port for receiving. */
-    public ConcurrentMulticastSocket(int port) throws IOException {
-        this.sock = new MulticastSocket(port);
-    }
-
-    /** Join a multicast group. */
-    public synchronized void joinGroup(InetAddress mcastaddr) throws IOException {
-        sock.joinGroup(mcastaddr);
-    }
-
-    public synchronized void send(DatagramPacket p) throws IOException {
-        sock.send(p);
-    }
-
-    public synchronized void receive(DatagramPacket p) throws IOException {
-        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();
-    }
-}
diff --git a/src/main/java/derms/net/rmulticast/ReliableMulticast.java b/src/main/java/derms/net/rmulticast/ReliableMulticast.java
index b194c96..f3db55c 100644
--- a/src/main/java/derms/net/rmulticast/ReliableMulticast.java
+++ b/src/main/java/derms/net/rmulticast/ReliableMulticast.java
@@ -1,10 +1,8 @@
 package derms.net.rmulticast;
 
 import derms.io.Serial;
-import derms.net.ConcurrentMulticastSocket;
 import derms.net.MessagePayload;
 import derms.net.Net;
-import derms.net.Packet;
 import derms.util.ThreadPool;
 
 import java.io.IOException;