full reconnect on leave with canReconnect

@@ -76,6 +76,8 @@ internal constructor(
         }
         }
 
 
     private var reconnectingJob: Job? = null
     private var reconnectingJob: Job? = null
+    private var fullReconnectOnNext = false
+
     private val pendingTrackResolvers: MutableMap<String, Continuation<LivekitModels.TrackInfo>> =
     private val pendingTrackResolvers: MutableMap<String, Continuation<LivekitModels.TrackInfo>> =
         mutableMapOf()
         mutableMapOf()
     private var sessionUrl: String? = null
     private var sessionUrl: String? = null
@@ -340,7 +342,8 @@ internal constructor(
             LKLog.w { "couldn't reconnect, no url or no token" }
             LKLog.w { "couldn't reconnect, no url or no token" }
             return
             return
         }
         }
-
+        val forceFullReconnect = fullReconnectOnNext
+        fullReconnectOnNext = false
         val job = coroutineScope.launch {
         val job = coroutineScope.launch {
             connectionState = ConnectionState.RECONNECTING
             connectionState = ConnectionState.RECONNECTING
             listener?.onEngineReconnecting()
             listener?.onEngineReconnecting()
@@ -356,7 +359,7 @@ internal constructor(
                 delay(startDelay)
                 delay(startDelay)
 
 
                 // full reconnect after first try.
                 // full reconnect after first try.
-                val isFullReconnect = retries != 0
+                val isFullReconnect = retries != 0 || forceFullReconnect
 
 
                 if (isFullReconnect) {
                 if (isFullReconnect) {
                     try {
                     try {
@@ -676,9 +679,14 @@ internal constructor(
     }
     }
 
 
     override fun onLeave(leave: LivekitRtc.LeaveRequest) {
     override fun onLeave(leave: LivekitRtc.LeaveRequest) {
+        if (leave.canReconnect) {
+            // reconnect will be triggered on close.
+            fullReconnectOnNext = true
+        } else {
             close()
             close()
             listener?.onEngineDisconnected("server leave")
             listener?.onEngineDisconnected("server leave")
         }
         }
+    }
 
 
     // Signal error
     // Signal error
     override fun onError(error: Throwable) {
     override fun onError(error: Throwable) {