From 72dc9368fb672e361af3bcae114eb02e4160a275 Mon Sep 17 00:00:00 2001 From: Vitor Pamplona Date: Tue, 2 Dec 2025 16:05:23 -0500 Subject: [PATCH] Fixes missing emit for null events --- .../amethyst/model/topNavFeeds/noteBased/NoteFeedFlow.kt | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/amethyst/src/main/java/com/vitorpamplona/amethyst/model/topNavFeeds/noteBased/NoteFeedFlow.kt b/amethyst/src/main/java/com/vitorpamplona/amethyst/model/topNavFeeds/noteBased/NoteFeedFlow.kt index 1bd864bb4..60a132e31 100644 --- a/amethyst/src/main/java/com/vitorpamplona/amethyst/model/topNavFeeds/noteBased/NoteFeedFlow.kt +++ b/amethyst/src/main/java/com/vitorpamplona/amethyst/model/topNavFeeds/noteBased/NoteFeedFlow.kt @@ -43,6 +43,7 @@ import com.vitorpamplona.quartz.nip51Lists.peopleList.PeopleListEvent import com.vitorpamplona.quartz.nip72ModCommunities.definition.CommunityDefinitionEvent import com.vitorpamplona.quartz.nip72ModCommunities.follow.CommunityListEvent import kotlinx.coroutines.ExperimentalCoroutinesApi +import kotlinx.coroutines.flow.Flow import kotlinx.coroutines.flow.FlowCollector import kotlinx.coroutines.flow.StateFlow import kotlinx.coroutines.flow.combineTransform @@ -220,11 +221,11 @@ class NoteFeedFlow( } @OptIn(ExperimentalCoroutinesApi::class) - override fun flow() = + override fun flow(): Flow = combineTransform(metadataFlow, outboxRelays, proxyRelays) { noteState, outboxRelays, proxyRelays -> val noteEvent = noteState?.note?.event if (noteEvent == null) { - AuthorsByOutboxTopNavFilter(emptySet(), blockedRelays) + emit(AuthorsByOutboxTopNavFilter(emptySet(), blockedRelays)) } else { if (proxyRelays.isEmpty()) { processByOutbox(noteEvent, outboxRelays)