nick/amethyst
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

Fixes missing emit for null events

Browse Source
This commit is contained in:
Vitor Pamplona
2025-12-02 16:05:23 -05:00
parent 71dc25099e
commit 72dc9368fb
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
amethyst/src/main/java/com/vitorpamplona/amethyst/model/topNavFeeds/noteBased/NoteFeedFlow.kt
+3 -2
View File
@@ -43,6 +43,7 @@ import com.vitorpamplona.quartz.nip51Lists.peopleList.PeopleListEvent
import com.vitorpamplona.quartz.nip72ModCommunities.definition.CommunityDefinitionEvent import com.vitorpamplona.quartz.nip72ModCommunities.definition.CommunityDefinitionEvent
import com.vitorpamplona.quartz.nip72ModCommunities.follow.CommunityListEvent import com.vitorpamplona.quartz.nip72ModCommunities.follow.CommunityListEvent
import kotlinx.coroutines.ExperimentalCoroutinesApi import kotlinx.coroutines.ExperimentalCoroutinesApi
import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.flow.FlowCollector import kotlinx.coroutines.flow.FlowCollector
import kotlinx.coroutines.flow.StateFlow import kotlinx.coroutines.flow.StateFlow
import kotlinx.coroutines.flow.combineTransform import kotlinx.coroutines.flow.combineTransform
@@ -220,11 +221,11 @@ class NoteFeedFlow(
} }
@OptIn(ExperimentalCoroutinesApi::class) @OptIn(ExperimentalCoroutinesApi::class)
override fun flow() = override fun flow(): Flow<IFeedTopNavFilter> =
combineTransform(metadataFlow, outboxRelays, proxyRelays) { noteState, outboxRelays, proxyRelays -> combineTransform(metadataFlow, outboxRelays, proxyRelays) { noteState, outboxRelays, proxyRelays ->
val noteEvent = noteState?.note?.event val noteEvent = noteState?.note?.event
if (noteEvent == null) { if (noteEvent == null) {
AuthorsByOutboxTopNavFilter(emptySet(), blockedRelays) emit(AuthorsByOutboxTopNavFilter(emptySet(), blockedRelays))
} else { } else {
if (proxyRelays.isEmpty()) { if (proxyRelays.isEmpty()) {
processByOutbox(noteEvent, outboxRelays) processByOutbox(noteEvent, outboxRelays)