diff options
Diffstat (limited to 'android/app/src')
| -rw-r--r-- | android/app/src/main/kotlin/net/mullvad/mullvadvpn/service/ForegroundNotificationManager.kt | 11 |
1 files changed, 8 insertions, 3 deletions
diff --git a/android/app/src/main/kotlin/net/mullvad/mullvadvpn/service/ForegroundNotificationManager.kt b/android/app/src/main/kotlin/net/mullvad/mullvadvpn/service/ForegroundNotificationManager.kt index b961de947d..0bf7e54606 100644 --- a/android/app/src/main/kotlin/net/mullvad/mullvadvpn/service/ForegroundNotificationManager.kt +++ b/android/app/src/main/kotlin/net/mullvad/mullvadvpn/service/ForegroundNotificationManager.kt @@ -8,6 +8,7 @@ import kotlinx.coroutines.channels.Channel import kotlinx.coroutines.channels.actor import kotlinx.coroutines.channels.sendBlocking import kotlinx.coroutines.flow.collect +import kotlinx.coroutines.flow.onStart import net.mullvad.mullvadvpn.model.DeviceState import net.mullvad.mullvadvpn.model.TunnelState import net.mullvad.mullvadvpn.service.endpoint.ConnectionProxy @@ -55,9 +56,13 @@ class ForegroundNotificationManager( intermittentDaemon.registerListener(this) { daemon -> jobTracker.newBackgroundJob("notificationLoggedInJob") { - daemon?.deviceStateUpdates?.collect { deviceState -> - loggedIn = deviceState is DeviceState.LoggedIn - } + daemon?.deviceStateUpdates + ?.onStart { + emit(daemon.getAndEmitDeviceState()) + } + ?.collect { deviceState -> + loggedIn = deviceState is DeviceState.LoggedIn + } } } |