From 1a70a02b442183d5eebf53688629b9b7f7b893a7 Mon Sep 17 00:00:00 2001
From: Vitor Pamplona <vitor@vitorpamplona.com>
Date: Wed, 10 Jul 2024 16:04:39 -0400
Subject: [PATCH] Fixes scoping issues with flattenMerge

---
 .../vitorpamplona/amethyst/model/Account.kt   | 23 ++++++++-----------
 1 file changed, 10 insertions(+), 13 deletions(-)

diff --git a/amethyst/src/main/java/com/vitorpamplona/amethyst/model/Account.kt b/amethyst/src/main/java/com/vitorpamplona/amethyst/model/Account.kt
index 1995916c5..7ce523620 100644
--- a/amethyst/src/main/java/com/vitorpamplona/amethyst/model/Account.kt
+++ b/amethyst/src/main/java/com/vitorpamplona/amethyst/model/Account.kt
@@ -119,7 +119,7 @@ import kotlinx.coroutines.flow.SharingStarted
 import kotlinx.coroutines.flow.StateFlow
 import kotlinx.coroutines.flow.combineTransform
 import kotlinx.coroutines.flow.flatMapLatest
-import kotlinx.coroutines.flow.flattenMerge
+import kotlinx.coroutines.flow.map
 import kotlinx.coroutines.flow.mapLatest
 import kotlinx.coroutines.flow.stateIn
 import kotlinx.coroutines.flow.transformLatest
@@ -481,10 +481,9 @@ class Account(
 
     @OptIn(ExperimentalCoroutinesApi::class)
     private val liveNotificationList: Flow<ListNameNotePair> by lazy {
-        defaultNotificationFollowList
-            .transformLatest { listName ->
-                emit(loadPeopleListFlowFromListName(listName))
-            }.flattenMerge()
+        defaultNotificationFollowList.flatMapLatest { listName ->
+            loadPeopleListFlowFromListName(listName)
+        }
     }
 
     val liveNotificationFollowLists: StateFlow<LiveFollowLists?> by lazy {
@@ -494,10 +493,9 @@ class Account(
 
     @OptIn(ExperimentalCoroutinesApi::class)
     private val liveStoriesList: Flow<ListNameNotePair> by lazy {
-        defaultStoriesFollowList
-            .transformLatest { listName ->
-                emit(loadPeopleListFlowFromListName(listName))
-            }.flattenMerge()
+        defaultStoriesFollowList.flatMapLatest { listName ->
+            loadPeopleListFlowFromListName(listName)
+        }
     }
 
     val liveStoriesFollowLists: StateFlow<LiveFollowLists?> by lazy {
@@ -507,10 +505,9 @@ class Account(
 
     @OptIn(ExperimentalCoroutinesApi::class)
     private val liveDiscoveryList: Flow<ListNameNotePair> by lazy {
-        defaultDiscoveryFollowList
-            .transformLatest { listName ->
-                emit(loadPeopleListFlowFromListName(listName))
-            }.flattenMerge()
+        defaultDiscoveryFollowList.flatMapLatest { listName ->
+            loadPeopleListFlowFromListName(listName)
+        }
     }
 
     val liveDiscoveryFollowLists: StateFlow<LiveFollowLists?> by lazy {