From 38641c88b71ac3300829a3bb3304712adc1f6662 Mon Sep 17 00:00:00 2001
From: Benoit Marty <benoit@matrix.org>
Date: Wed, 18 May 2022 20:51:41 +0200
Subject: [PATCH] Fix usage of System.currentTimeMillis(). This a bit mocky but
 anyway it's better to use SystemClock.elapsedRealtime() for this case.

---
 .../java/im/vector/lib/core/utils/flow/TimingOperators.kt    | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/library/core-utils/src/main/java/im/vector/lib/core/utils/flow/TimingOperators.kt b/library/core-utils/src/main/java/im/vector/lib/core/utils/flow/TimingOperators.kt
index 2efb439ace..aeb5ae7914 100644
--- a/library/core-utils/src/main/java/im/vector/lib/core/utils/flow/TimingOperators.kt
+++ b/library/core-utils/src/main/java/im/vector/lib/core/utils/flow/TimingOperators.kt
@@ -16,6 +16,7 @@
 
 package im.vector.lib.core.utils.flow
 
+import android.os.SystemClock
 import kotlinx.coroutines.CoroutineScope
 import kotlinx.coroutines.ExperimentalCoroutinesApi
 import kotlinx.coroutines.channels.Channel
@@ -68,10 +69,10 @@ fun <T> Flow<T>.chunk(durationInMillis: Long): Flow<List<T>> {
 
 @ExperimentalCoroutinesApi
 fun <T> Flow<T>.throttleFirst(windowDuration: Long): Flow<T> = flow {
-    var windowStartTime = System.currentTimeMillis()
+    var windowStartTime = SystemClock.elapsedRealtime()
     var emitted = false
     collect { value ->
-        val currentTime = System.currentTimeMillis()
+        val currentTime = SystemClock.elapsedRealtime()
         val delta = currentTime - windowStartTime
         if (delta >= windowDuration) {
             windowStartTime += delta / windowDuration * windowDuration