Use coroutine scope insteand of using runBlocking for rejoining

GetStream · Jan 3, 2025 · b976ad1 · b976ad1
1 parent d35dea4
commit b976ad1
Showing 1 changed file with 4 additions and 5 deletions.
diff --git a/stream-video-android-core/src/main/kotlin/io/getstream/video/android/core/call/RtcSession.kt b/stream-video-android-core/src/main/kotlin/io/getstream/video/android/core/call/RtcSession.kt
@@ -97,7 +97,6 @@ import kotlinx.coroutines.flow.flowOn
 import kotlinx.coroutines.flow.retry
 import kotlinx.coroutines.flow.retryWhen
 import kotlinx.coroutines.launch
-import kotlinx.coroutines.runBlocking
 import kotlinx.coroutines.withContext
 import kotlinx.serialization.encodeToString
 import kotlinx.serialization.json.Json
@@ -1729,7 +1728,7 @@ public class RtcSession internal constructor(
         }
     }
 
-    private suspend fun parseError(e: Throwable): Failure {
+    private fun parseError(e: Throwable): Failure {
         return Failure(
             io.getstream.result.Error.ThrowableError(
                 "CallClientImpl error needs to be handled",
@@ -1909,11 +1908,11 @@ public class RtcSession internal constructor(
         stateJob?.cancel()
         eventJob?.cancel()
         errorJob?.cancel()
-        runBlocking {
+        coroutineScope.launch {
             sfuConnectionModule.socketConnection.disconnect()
+            publisher?.connection?.close()
+            subscriber?.connection?.close()
         }
-        publisher?.connection?.close()
-        subscriber?.connection?.close()
     }
 
     internal fun prepareReconnect() {