fix(store): replace null check with Option for stream messages

2026-05-31 16:27:22 +02:00
parent a253fa78df
commit 252851de1c
1 changed files with 1 additions and 1 deletions
@@ -61,7 +61,7 @@ class GameWritebackStreamListener:
          ">",
          new XReadGroupArgs().count(10).block(java.time.Duration.ofSeconds(2)),
        )
-        if messages != null then messages.forEach(msg => handleMessage(msg))
+        Option(messages).foreach(_.forEach(msg => handleMessage(msg)))
      } match
        case Failure(ex) => log.warnf(ex, "Error in writeback poll loop")
        case Success(_)  => ()