commit f5b020e292eab626f145f96d40ddf8afccbb95ba
author Luca Stefani <luca.stefani.ge1@gmail.com> Tue Aug 15 19:44:08 2023 +0200
committer Sebastiano Barezzi <seba@sebaubuntu.dev> Sat Aug 19 15:58:59 2023 +0200
tree 631d2e4544ab020d15c2c822e3319a8a351ea63f
parent 2790d4977dbc100bf87a1af07187933228707fe9

Glimpse: Conflate any flow from URIs

If we get a lot of new files we want to drop any "old" event

Change-Id: I913672d4b651ca0473edc530e0f57996fd4b6830

app/src/main/java/org/lineageos/glimpse/ext/ContentResolver.kt

diff --git a/app/src/main/java/org/lineageos/glimpse/ext/ContentResolver.kt b/app/src/main/java/org/lineageos/glimpse/ext/ContentResolver.kt
index b6a7da1..ceb4b39 100644
--- a/app/src/main/java/org/lineageos/glimpse/ext/ContentResolver.kt
+++ b/app/src/main/java/org/lineageos/glimpse/ext/ContentResolver.kt
@@ -18,6 +18,7 @@
 import androidx.annotation.RequiresApi
 import kotlinx.coroutines.channels.awaitClose
 import kotlinx.coroutines.flow.callbackFlow
+import kotlinx.coroutines.flow.conflate
 import kotlinx.coroutines.flow.map
 
 @RequiresApi(Build.VERSION_CODES.R)
@@ -50,7 +51,7 @@
     awaitClose {
         unregisterContentObserver(observer)
     }
-}
+}.conflate()
 
 fun ContentResolver.queryFlow(
     uri: Uri,