RUDP. impl. StartServerSideConnection

alec1o · Jul 3, 2024 · f176661 · f176661
1 parent c0f234c
commit f176661
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/src/rudp/partials/RUDP.ClientTo.cs b/src/rudp/partials/RUDP.ClientTo.cs
@@ -275,7 +275,7 @@ public void InjectBuffer(ref byte[] bytes)
 
             public void StartServerSideConnection(ref Action<bool> callback)
             {
-                throw new NotImplementedException();
+                _connection.OnServer = callback;
             }
 
             private void InitReceiver()

diff --git a/src/rudp/partials/utils/RUDP.Connection.cs b/src/rudp/partials/utils/RUDP.Connection.cs
@@ -20,6 +20,7 @@ internal sealed class Connection
             private bool _isOpeningOrClosing;
             public Action OnOpen, OnClose;
             public Action<string> OnOpenFail;
+            public Action<bool> OnServer;
             public Action<byte[], MessageType> OnData;
             public Action<string, byte[], MessageType> OnEvent;
             private readonly object _sendIdLocker, _databaseLocker;
@@ -60,6 +61,7 @@ public Connection(Host host, Socket socket, bool isServer) : this()
             public Task Open(int timeout)
             {
                 if (_isOpeningOrClosing || IsOpened) return Task.CompletedTask;
+                _isOpeningOrClosing = true;
 
                 return Task.Run(() =>
                 {
@@ -70,6 +72,7 @@ public Task Open(int timeout)
             public Task Close()
             {
                 if (_isOpeningOrClosing || !IsOpened) return Task.CompletedTask;
+                _isOpeningOrClosing = true;
 
                 return Task.Run(() =>
                 {