Allow set connect retry to connect function

livekit-android-sdk/src/main/java/io/livekit/android/LiveKit.kt

@@ -6,6 +6,7 @@ import io.livekit.android.room.Room
 import io.livekit.android.room.RoomListener
 import io.livekit.android.util.LKLog
 import io.livekit.android.util.LoggingLevel
+import io.livekit.android.util.executeSuspendWithRetry
 import timber.log.Timber
 
 class LiveKit {
@@ -59,19 +60,23 @@ class LiveKit {
          * Connect to a LiveKit room
          * @param url URL to LiveKit server (i.e. ws://mylivekitdeploy.io)
          * @param listener Listener to Room events. LiveKit interactions take place with these callbacks
+         * @param maxConnectRetry Int to set max connect retry.
          */
         suspend fun connect(
             appContext: Context,
             url: String,
             token: String,
             options: ConnectOptions = ConnectOptions(),
             roomOptions: RoomOptions = RoomOptions(),
-            listener: RoomListener? = null
+            listener: RoomListener? = null ,
+            maxConnectRetry: Int = 0
         ): Room {
             val room = create(appContext, roomOptions)
 
             room.listener = listener
-            room.connect(url, token, options)
+            executeSuspendWithRetry(maxConnectRetry){
+                room.connect(url, token, options)
+            }
             return room
         }
 

livekit-android-sdk/src/main/java/io/livekit/android/util/ExcuteSuspendWithRetry.kt

@@ -0,0 +1,24 @@
+package io.livekit.android.util
+
+import kotlinx.coroutines.delay
+
+suspend fun <T>executeSuspendWithRetry(maxRetries: Int, suspendFunction: suspend () -> T): T {
+    var currentAttempt = 0
+    var lastException: Exception? = null
+
+    while (currentAttempt <= maxRetries) {
+        try {
+            return suspendFunction()
+        } catch (e: Exception) {
+            LKLog.i {"connection number $currentAttempt failed with $e"}
+            // Store the last exception for error logging
+            lastException = e
+            currentAttempt++
+
+            // Delay before retrying
+            delay(1_000L * currentAttempt)
+        }
+    }
+
+    throw lastException ?: RuntimeException("Max retries exceeded")
+}