summaryrefslogtreecommitdiffhomepage
path: root/android/lib
diff options
context:
space:
mode:
Diffstat (limited to 'android/lib')
-rw-r--r--android/lib/daemon-grpc/src/main/kotlin/net/mullvad/mullvadvpn/lib/daemon/grpc/util/ManagedChannel.kt6
1 files changed, 3 insertions, 3 deletions
diff --git a/android/lib/daemon-grpc/src/main/kotlin/net/mullvad/mullvadvpn/lib/daemon/grpc/util/ManagedChannel.kt b/android/lib/daemon-grpc/src/main/kotlin/net/mullvad/mullvadvpn/lib/daemon/grpc/util/ManagedChannel.kt
index a0e5bd5fd1..8ce5a10876 100644
--- a/android/lib/daemon-grpc/src/main/kotlin/net/mullvad/mullvadvpn/lib/daemon/grpc/util/ManagedChannel.kt
+++ b/android/lib/daemon-grpc/src/main/kotlin/net/mullvad/mullvadvpn/lib/daemon/grpc/util/ManagedChannel.kt
@@ -3,13 +3,11 @@ package net.mullvad.mullvadvpn.lib.daemon.grpc.util
import co.touchlab.kermit.Logger
import io.grpc.ConnectivityState
import io.grpc.ManagedChannel
-import kotlinx.coroutines.ExperimentalCoroutinesApi
import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.flow.callbackFlow
import kotlinx.coroutines.isActive
import kotlinx.coroutines.suspendCancellableCoroutine
-@OptIn(ExperimentalCoroutinesApi::class)
internal fun ManagedChannel.connectivityFlow(): Flow<ConnectivityState> {
return callbackFlow {
var currentState = getState(false)
@@ -20,7 +18,9 @@ internal fun ManagedChannel.connectivityFlow(): Flow<ConnectivityState> {
currentState = suspendCancellableCoroutine {
notifyWhenStateChanged(currentState) {
// If we are cancelled we will just log
- it.resume(getState(false)) { Logger.w("Resume while cancelled", it) }
+ it.resume(getState(false)) { cause, value, _ ->
+ Logger.w("Resume while cancelled, value: $value", cause)
+ }
}
}
}