MDS/openide
1
0
Fork 0
mirror of https://gitflic.ru/project/openide/openide.git synced 2026-03-22 15:10:43 +07:00
Code Issues Packages Projects Releases Wiki Activity

[fleet] use an unlimited channel while processing db changes in rete

Browse Source 
GitOrigin-RevId: 1a1be92e2c902e4fead807a9dd07b51e4d045cd4
This commit is contained in:
Alexander Zolotov
2024-09-30 21:13:53 +02:00
committed by intellij-monorepo-bot
parent 736217f797
commit 96b933e241
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
fleet/kernel/src/fleet/kernel/rete/Rete.kt
View File

@@ -60,7 +60,7 @@ suspend fun<T> withRete(failWhenPropagationFailed: Boolean = false, body: suspen
val (commandsSender, commandsReceiver) = channels<Rete.Command>(Channel.UNLIMITED)
return spannedScope("withRete") {
val kernel = transactor()
kernel.subscribe { db, changes ->
kernel.subscribe(Channel.UNLIMITED) { db, changes ->
val lastKnownDb = MutableStateFlow(db)
launch {
spannedScope("rete event loop") {