From 2d4db9fea83242a2512519422665a017096abd88 Mon Sep 17 00:00:00 2001 From: Vitor Pamplona Date: Tue, 28 May 2024 19:09:53 -0400 Subject: [PATCH] Refactoring on latestbykindandetag --- .../amethyst/model/observables/LatestByKindWithETag.kt | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/app/src/main/java/com/vitorpamplona/amethyst/model/observables/LatestByKindWithETag.kt b/app/src/main/java/com/vitorpamplona/amethyst/model/observables/LatestByKindWithETag.kt index c1ebd5a1f..30796daa0 100644 --- a/app/src/main/java/com/vitorpamplona/amethyst/model/observables/LatestByKindWithETag.kt +++ b/app/src/main/java/com/vitorpamplona/amethyst/model/observables/LatestByKindWithETag.kt @@ -30,8 +30,10 @@ class LatestByKindWithETag(private val kind: Int, private val eTag: S private val _latest = MutableStateFlow(null) val latest = _latest.asStateFlow() + fun matches(event: T) = event.kind == kind && event.isTaggedEvent(eTag) + fun updateIfMatches(event: T) { - if (event.kind == kind && event.isTaggedEvent(eTag)) { + if (matches(event)) { if (event.createdAt > (_latest.value?.createdAt ?: 0)) { _latest.tryEmit(event) }