diff options
| author | David Göransson <david.goransson@mullvad.net> | 2024-10-02 09:47:44 +0200 |
|---|---|---|
| committer | David Göransson <david.goransson@mullvad.net> | 2024-10-03 08:52:02 +0200 |
| commit | 9abb82bcc3a584ce342b2accab8ac63b3e3c9a52 (patch) | |
| tree | 145721755630789ba26e4cc3ef009912b50436de /android | |
| parent | 70ff213b3fd9c214b84e1b68cd53f61f8897876c (diff) | |
| download | mullvadvpn-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.kt | 6 |
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) + } } } } |
