Fix network manager not removing old instances

DreamExposure · Mar 23, 2024 · 5a2af29 · 5a2af29
1 parent 4e37215
commit 5a2af29
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/server/src/main/kotlin/org/dreamexposure/discal/server/network/discal/NetworkManager.kt b/server/src/main/kotlin/org/dreamexposure/discal/server/network/discal/NetworkManager.kt
@@ -98,10 +98,10 @@ class NetworkManager(
         Flux.interval(Duration.ofMinutes(1))
             .flatMap { updateAndReturnStatus() } //Update local status every minute
             .flatMap {
-                val bot = Flux.from<BotInstanceData> { status.botStatus }
+                val bot = Flux.fromIterable(status.botStatus)
                     .filter { Instant.now().isAfter(it.instanceData.lastHeartbeat.plus(5, ChronoUnit.MINUTES)) }
                     .flatMap(this::doRestartBot)
-                val cam = Flux.from<InstanceData> { status.camStatus }
+                val cam = Flux.fromIterable(status.camStatus)
                     .filter { Instant.now().isAfter(it.lastHeartbeat.plus(5, ChronoUnit.MINUTES)) }
                     .flatMap(this::doRestartCam)