From 9773f552e63b7a868431e67a52191b933457f387 Mon Sep 17 00:00:00 2001
From: Captain ALM <captainalm@captainalm.com>
Date: Sun, 21 May 2023 22:56:19 +0100
Subject: [PATCH] Update to latest NetMarshalClient UDP implement.

---
 src/com/captainalm/test/calmnet/Main.java | 14 ++------------
 1 file changed, 2 insertions(+), 12 deletions(-)

diff --git a/src/com/captainalm/test/calmnet/Main.java b/src/com/captainalm/test/calmnet/Main.java
index a469d6e..7adae1a 100644
--- a/src/com/captainalm/test/calmnet/Main.java
+++ b/src/com/captainalm/test/calmnet/Main.java
@@ -147,7 +147,6 @@ public final class Main {
         server = null;
         client = null;
         sslUpgraded = false;
-        boolean connectFromServer = false;
         switch (opt) {
             case '0':
                 sendLoopsRemainingSetting = 1;
@@ -185,8 +184,7 @@ public final class Main {
                 requestSendSettings();
                 try {
                     DatagramSocket socket = new DatagramSocket();
-                    server = new NetMarshalServer(socket, factory, factory.getPacketLoader(), fragOpts);
-                    connectFromServer = true;
+                    client = new NetMarshalClient(socket, address, port, factory, factory.getPacketLoader(), fragOpts);
                     isClient = true;
                 } catch (IOException e) {
                     e.printStackTrace();
@@ -207,8 +205,7 @@ public final class Main {
                 requestSendSettings();
                 try {
                     DatagramSocket socket = new DatagramSocket(port, address);
-                    server = new NetMarshalServer(socket, factory, factory.getPacketLoader(), fragOpts);
-                    connectFromServer = true;
+                    client = new NetMarshalClient(socket, address, port, factory, factory.getPacketLoader(), fragOpts);
                     isClient = true;
                 } catch (IOException e) {
                     e.printStackTrace();
@@ -262,13 +259,6 @@ public final class Main {
                 server.setOpenedConsumer(Main::connectH);
                 server.setClosedConsumer(Main::closeH);
                 server.open();
-                if (connectFromServer) {
-                    try {
-                        server.connect(address, port, 0);
-                    } catch (IOException e) {
-                        e.printStackTrace();
-                    }
-                }
             }
             if (client != null) {
                 client.setReceiveExceptionBiConsumer(Main::errH);