From 77d4f5f57f8164ff8ebb3cee1defa1fac3aec73e Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Tom=C3=A1=C5=A1=20Mlynari=C4=8D?= <mlykotom@google.com>
Date: Tue, 6 Feb 2024 15:04:24 +0100
Subject: [PATCH] Use trySend multiple times

Change-Id: Ie00c4180d07fc4bb9d457647f3b7ddadd5a3c032
---
 .../com/google/samples/apps/nowinandroid/ui/NiaAppState.kt | 2 +-
 .../apps/nowinandroid/core/data/util/TimeZoneMonitor.kt    | 7 +++++++
 2 files changed, 8 insertions(+), 1 deletion(-)

diff --git a/app/src/main/kotlin/com/google/samples/apps/nowinandroid/ui/NiaAppState.kt b/app/src/main/kotlin/com/google/samples/apps/nowinandroid/ui/NiaAppState.kt
index ec2be6511..d423adfbf 100644
--- a/app/src/main/kotlin/com/google/samples/apps/nowinandroid/ui/NiaAppState.kt
+++ b/app/src/main/kotlin/com/google/samples/apps/nowinandroid/ui/NiaAppState.kt
@@ -89,7 +89,7 @@ class NiaAppState(
     val windowSizeClass: WindowSizeClass,
     networkMonitor: NetworkMonitor,
     userNewsResourceRepository: UserNewsResourceRepository,
-    private val timeZoneMonitor: TimeZoneMonitor,
+    timeZoneMonitor: TimeZoneMonitor,
 ) {
     val currentDestination: NavDestination?
         @Composable get() = navController
diff --git a/core/data/src/main/kotlin/com/google/samples/apps/nowinandroid/core/data/util/TimeZoneMonitor.kt b/core/data/src/main/kotlin/com/google/samples/apps/nowinandroid/core/data/util/TimeZoneMonitor.kt
index d75f81efc..6e206e67c 100644
--- a/core/data/src/main/kotlin/com/google/samples/apps/nowinandroid/core/data/util/TimeZoneMonitor.kt
+++ b/core/data/src/main/kotlin/com/google/samples/apps/nowinandroid/core/data/util/TimeZoneMonitor.kt
@@ -35,6 +35,7 @@ import kotlinx.coroutines.flow.SharedFlow
 import kotlinx.coroutines.flow.SharingStarted
 import kotlinx.coroutines.flow.callbackFlow
 import kotlinx.coroutines.flow.conflate
+import kotlinx.coroutines.flow.distinctUntilChanged
 import kotlinx.coroutines.flow.flowOn
 import kotlinx.coroutines.flow.shareIn
 import kotlinx.datetime.TimeZone
@@ -87,10 +88,16 @@ internal class TimeZoneBroadcastMonitor @Inject constructor(
                 context.registerReceiver(receiver, IntentFilter(Intent.ACTION_TIMEZONE_CHANGED))
             }
 
+            // Send here again, because registering the Broadcast Receiver can take up to several milliseconds.
+            // This way, we can reduce the likelihood that a TZ change wouldn't be caught with the Broadcast Receiver.
+            trySend(TimeZone.currentSystemDefault())
+
             awaitClose {
                 context.unregisterReceiver(receiver)
             }
         }
+            // We use to prevent multiple emissions of the same type, because we use trySend multiple times.
+            .distinctUntilChanged()
             .conflate()
             .flowOn(ioDispatcher)
             // Sharing the callback to prevent multiple BroadcastReceivers being registered