Simplifies flow collection for new events.

This commit is contained in:
Vitor Pamplona
2024-08-26 18:22:12 -04:00
parent 66ed26dcea
commit 7b8c7a1a78

View File

@@ -1197,23 +1197,21 @@ class AccountViewModel(
init { init {
Log.d("Init", "AccountViewModel") Log.d("Init", "AccountViewModel")
viewModelScope.launch(Dispatchers.Default) { collectorJob =
feedStates.init() viewModelScope.launch(Dispatchers.Default) {
// awaits for init to finish before starting to capture new events. feedStates.init()
// awaits for init to finish before starting to capture new events.
collectorJob = LocalCache.live.newEventBundles.collect { newNotes ->
viewModelScope.launch(Dispatchers.IO) { Log.d(
LocalCache.live.newEventBundles.collect { newNotes -> "Rendering Metrics",
Log.d( "Notification Dots Calculation refresh ${this@AccountViewModel} for ${account.userProfile().toBestDisplayName()}",
"Rendering Metrics", )
"Notification Dots Calculation refresh ${this@AccountViewModel} for ${account.userProfile().toBestDisplayName()}", feedStates.updateFeedsWith(newNotes)
) invalidateInsertData(newNotes)
feedStates.updateFeedsWith(newNotes) upgradeAttestations()
invalidateInsertData(newNotes)
upgradeAttestations()
}
} }
} }
} }
override fun onCleared() { override fun onCleared() {