bugfix: After fixing the failure of RTC reconnection and WebSocket connection, no notification was sent to the upper-layer application.

Author: CMzhizhe

livekit-android-sdk/src/main/java/io/livekit/android/room/RTCEngine.kt

@@ -142,6 +142,10 @@ internal constructor(
             ConnectionState.DISCONNECTED -> {
                 LKLog.d { "primary ICE disconnected" }
                 if (oldVal == ConnectionState.CONNECTED) {
+                    LKLog.d { "ready call reconnect()" }
+                    reconnect()
+                } else if (oldVal == ConnectionState.RESUMING || oldVal == ConnectionState.RECONNECTING) {
+                    LKLog.d { "ICE disconnected during reconnect, retrying reconnect()" }
                     reconnect()
                 }
             }
@@ -307,7 +311,14 @@ internal constructor(
                     if (newState.isConnected()) {
                         connectionState = ConnectionState.CONNECTED
                     } else if (newState.isDisconnected()) {
-                        connectionState = ConnectionState.DISCONNECTED
+                        // Only transition to DISCONNECTED when not already in a reconnection
+                        // intermediate state (RESUMING/RECONNECTING). In those states the
+                        // reconnect flow owns connectionState; overwriting it here would
+                        // silently swallow the disconnect and prevent the app from being notified.
+                        val current = connectionState
+                        if (current != ConnectionState.RESUMING && current != ConnectionState.RECONNECTING) {
+                            connectionState = ConnectionState.DISCONNECTED
+                        }
                     }
                 }
 

livekit-android-sdk/src/main/java/io/livekit/android/room/SignalClient.kt

@@ -349,6 +349,9 @@ constructor(
             LKLog.e(e) { "failed to validate connection" }
         }
 
+        val wasConnected = isConnected
+        val wasConnecting = joinContinuation != null
+
         if (reason != null) {
             LKLog.e(t) { "websocket failure: $reason" }
             val error = Exception(reason)
@@ -361,11 +364,11 @@ constructor(
         }
         joinContinuation = null
 
-        val wasConnected = isConnected
-
-        if (wasConnected) {
+        if (wasConnected || wasConnecting) {
             // onClosing/onClosed will not be called after onFailure.
             // Handle websocket closure here.
+            // Also handle the case where failure occurs during a reconnect attempt (wasConnecting),
+            // where isConnected is already false but the upper layer still needs to be notified.
             handleWebSocketClose(
                 reason = reason ?: response?.toString() ?: t.localizedMessage ?: "websocket failure",
                 code = response?.code ?: CLOSE_REASON_WEBSOCKET_FAILURE,