Brendon/gameyfin
1
0
Fork 0
mirror of https://github.com/BrenBroZAYT/gameyfin.git synced 2026-06-16 16:20:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

Make realtime UI more robust

Browse Source
This commit is contained in:
grimsi
2025-05-21 16:07:50 +02:00
parent 83fb5ea1d0
commit bfe14706f7
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
gameyfin/src/main/kotlin/de/grimsi/gameyfin/config/ConfigService.kt
+1 -1
View File
@@ -19,7 +19,7 @@ class ConfigService(
private val log = KotlinLogging.logger {} private val log = KotlinLogging.logger {}
} }
private val configUpdates = Sinks.many().multicast().onBackpressureBuffer<ConfigUpdateDto>() private val configUpdates = Sinks.many().multicast().onBackpressureBuffer<ConfigUpdateDto>(1024, false)
fun subscribe(): Flux<ConfigUpdateDto> { fun subscribe(): Flux<ConfigUpdateDto> {
log.debug { "New subscription for configUpdates (#${configUpdates.currentSubscriberCount()})" } log.debug { "New subscription for configUpdates (#${configUpdates.currentSubscriberCount()})" }
gameyfin/src/main/kotlin/de/grimsi/gameyfin/core/plugins/PluginService.kt
+1 -1
View File
@@ -31,7 +31,7 @@ class PluginService(
private val log = KotlinLogging.logger {} private val log = KotlinLogging.logger {}
} }
private val pluginUpdates = Sinks.many().multicast().onBackpressureBuffer<PluginUpdateDto>() private val pluginUpdates = Sinks.many().multicast().onBackpressureBuffer<PluginUpdateDto>(1024, false)
private val pluginConfigValidationCache = mutableMapOf<String, PluginConfigValidationResult>() private val pluginConfigValidationCache = mutableMapOf<String, PluginConfigValidationResult>()
init { init {