feat: update codes for lower language version

Author: insthync

SimpleNetworkManager.NET/Network/BaseClientConnection.cs

@@ -12,10 +12,10 @@ namespace Insthync.SimpleNetworkManager.NET.Network
 {
     public abstract class BaseClientConnection : IDisposable
     {
-        private static uint s_connectionIdCounter = 0;
+        private static int s_connectionIdCounter = 0;
         private static ConcurrentQueue<uint> s_unassignedConnectionIds = new ConcurrentQueue<uint>();
 
-        private static uint s_requestIdCounter = 0;
+        private static int s_requestIdCounter = 0;
         private static ConcurrentQueue<uint> s_unassignedRequestIds = new ConcurrentQueue<uint>();
 
         protected readonly ILogger<BaseClientConnection> _logger;
@@ -37,17 +37,23 @@ public BaseClientConnection(ILogger<BaseClientConnection> logger)
             _pendingResponses = new ConcurrentDictionary<uint, BaseResponseMessage>();
         }
 
+        private static uint InterlockedIncrementUInt(ref int location)
+        {
+            Interlocked.Increment(ref location);
+            return location < 0 ? (uint)(location + (long)uint.MaxValue + 1) : (uint)location;
+        }
+
         private static uint GetNewConnectionId()
         {
             if (!s_unassignedConnectionIds.TryDequeue(out uint connectionId))
-                connectionId = Interlocked.Increment(ref s_connectionIdCounter);
+                connectionId = InterlockedIncrementUInt(ref s_connectionIdCounter);
             return connectionId;
         }
 
         private static uint GetNewRequestId()
         {
             if (!s_unassignedRequestIds.TryDequeue(out uint requestId))
-                requestId = Interlocked.Increment(ref s_requestIdCounter);
+                requestId = InterlockedIncrementUInt(ref s_requestIdCounter);
             return requestId;
         }
 
@@ -117,7 +123,7 @@ internal async UniTask<TResponse> SendRequestAsync<TResponse>(BaseRequestMessage
                 throw new TimeoutException($"Request timed out after {timeoutMs} milliseconds (RequestId: {requestId}).");
             }
 
-            if (response is not TResponse castedResponse)
+            if (!(response is TResponse castedResponse))
             {
                 throw new InvalidOperationException($"Response type mismatch. Expected {typeof(TResponse).Name}, got {response.GetType().Name}");
             }

SimpleNetworkManager.NET/Network/TcpTransport/TcpClientConnection.cs

@@ -17,7 +17,6 @@ public class TcpClientConnection : BaseClientConnection
         private readonly CancellationTokenSource _cancellationTokenSource;
         private readonly SemaphoreSlim _sendSemaphore;
 
-        private UniTask? _receiveTask;
         private bool _isConnected;
 
         public TcpClient TcpClient => _tcpClient;
@@ -312,10 +311,10 @@ internal override async UniTask SendMessageAsync(BaseMessage message)
             }
         }
 
-        internal override async UniTask DisconnectAsync()
+        internal override UniTask DisconnectAsync()
         {
             if (_disposed || !_isConnected)
-                return;
+                return UniTask.CompletedTask;
 
             _logger.LogInformation("Disconnecting client {ConnectionId}", ConnectionId);
 
@@ -332,25 +331,9 @@ internal override async UniTask DisconnectAsync()
                 _logger.LogWarning(ex, "Error during client {ConnectionId} disconnection", ConnectionId);
             }
 
-            // Wait for receive task to complete
-            if (_receiveTask != null)
-            {
-                try
-                {
-                    await _receiveTask.Value;
-                }
-                catch (OperationCanceledException)
-                {
-                    // Expected when cancellation is requested
-                }
-                catch (Exception ex)
-                {
-                    _logger.LogWarning(ex, "Error waiting for receive task completion for client {ConnectionId}", ConnectionId);
-                }
-            }
-
             // Raise disconnected event
             OnDisconnected();
+            return UniTask.CompletedTask;
         }
 
         public override async UniTask RejectConnectionAsync(ConnectionErrorTypes errorType, string errorText, bool shouldRetry, int retryDelayMs)