Merge pull request #167 from GetStream/feature/uni-125-fix-users-not-knowing-immediately-that-another-user-left-the

Fix waiting for the send queue when leaving the call (to make sure th…

Author: sierpinskid

Packages/StreamVideo/Runtime/Core/LowLevelClient/RtcSession.cs

@@ -418,17 +418,17 @@ public async Task StopAsync(string reason = "")
 
                 for (int i = 0; i < 60; i++)
                 {
-                    if (_sfuWebSocket.QueuedMessagesCount > 0)
+                    if (_sfuWebSocket.SendQueueCount > 0)
                     {
                         await Task.Delay(5);
                     }
                 }
 
 #if STREAM_DEBUG_ENABLED
-                if (_sfuWebSocket.QueuedMessagesCount > 0)
+                if (_sfuWebSocket.SendQueueCount > 0)
                 {
                     _logs.Error(
-                        $"Waited for 300+ ms for SFU messages to be sent. Remaining: {_sfuWebSocket.QueuedMessagesCount}");
+                        $"Waited for 300+ ms for SFU messages to be sent. Remaining: {_sfuWebSocket.SendQueueCount}");
                 }
 #endif
             }

Packages/StreamVideo/Runtime/Core/LowLevelClient/WebSockets/BasePersistentWebSocket.cs

@@ -298,7 +298,7 @@ private void OnConnectionFailed()
         private void OnDisconnected()
         {
 #if STREAM_DEBUG_ENABLED
-            Logs.Warning($"{LogsPrefix} Websocket Disconnected. Messages left: {WebsocketClient.QueuedMessagesCount}");
+            Logs.Warning($"{LogsPrefix} Websocket Disconnected. Messages left: {WebsocketClient.ReceiveQueueCount}");
 #endif
             ConnectionState = ConnectionState.Disconnected;
         }

Packages/StreamVideo/Runtime/Core/LowLevelClient/WebSockets/SfuWebSocket.cs

@@ -42,7 +42,7 @@ internal class SfuWebSocket : BasePersistentWebSocket
         public event Action<ChangePublishOptions> ChangePublishOptions;
         public event Action<InboundStateNotification> InboundStateNotification;
 
-        public int QueuedMessagesCount => WebsocketClient.QueuedMessagesCount;
+        public int SendQueueCount => WebsocketClient.SendQueueCount;
 
         public SfuWebSocket(IWebsocketClient websocketClient, IReconnectScheduler reconnectScheduler,
             IAuthProvider authProvider,

Packages/StreamVideo/Runtime/Libs/Websockets/IWebsocketClient.cs

@@ -12,7 +12,9 @@ public interface IWebsocketClient : IDisposable
         event Action Connected;
         event Action Disconnected;
         event Action ConnectionFailed;
-        int QueuedMessagesCount { get; }
+        
+        int ReceiveQueueCount { get; }
+        int SendQueueCount { get; }
 
         bool TryDequeueMessage(out byte[] message);
 

Packages/StreamVideo/Runtime/Libs/Websockets/NativeWebSocketWrapper.cs

@@ -20,7 +20,8 @@ public class NativeWebSocketWrapper : IWebsocketClient
         public event Action Disconnected;
         public event Action ConnectionFailed;
 
-        public int QueuedMessagesCount => _messages.Count;
+        public int ReceiveQueueCount => _messages.Count;
+        public int SendQueueCount => throw new NotImplementedException();
 
         public NativeWebSocketWrapper(ILogs logs, bool isDebugMode)
         {

Packages/StreamVideo/Runtime/Libs/Websockets/WebsocketClient.cs

@@ -25,7 +25,8 @@ public class WebsocketClient : IWebsocketClient
 
         public WebSocketState State => _internalClient?.State ?? WebSocketState.None;
 
-        public int QueuedMessagesCount => _receiveQueue.Count;
+        public int ReceiveQueueCount => _receiveQueue.Count;
+        public int SendQueueCount => _sendQueue.Count;
 
         /// <param name="isDebugMode">Additional logs will be printed</param>
         public WebsocketClient(ILogs logs, Encoding encoding = default, bool isDebugMode = false)