summaryrefslogtreecommitdiffhomepage
path: root/android
diff options
context:
space:
mode:
authorDavid Göransson <david.goransson@mullvad.net>2024-10-02 09:47:44 +0200
committerDavid Göransson <david.goransson@mullvad.net>2024-10-03 08:52:02 +0200
commit9abb82bcc3a584ce342b2accab8ac63b3e3c9a52 (patch)
tree145721755630789ba26e4cc3ef009912b50436de /android
parent70ff213b3fd9c214b84e1b68cd53f61f8897876c (diff)
downloadmullvadvpn-9abb82bcc3a584ce342b2accab8ac63b3e3c9a52.tar.xz
mullvadvpn-9abb82bcc3a584ce342b2accab8ac63b3e3c9a52.zip
Fix usage of deprecated lambda
Diffstat (limited to 'android')
-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)
+ }
}
}
}