Updated on 2026-08-14
This commit is contained in:
parent
d2e036e574
commit
ce006ff9b7
4 changed files with 25 additions and 12 deletions
|
|
@ -24,7 +24,9 @@ internal class DefaultQuotesStore(
|
|||
merge(*flows.toTypedArray())
|
||||
.scan<StoredQuote, Set<StoredQuote>>(emptySet()) { acc, quote ->
|
||||
acc.addOrReplace(quote) { it.rawCurrencyId == quote.rawCurrencyId }
|
||||
}.collect(::send)
|
||||
}
|
||||
.filter(Set<StoredQuote>::isNotEmpty)
|
||||
.collect(::send)
|
||||
}
|
||||
}
|
||||
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue