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

This commit is contained in:
Janis Eccarius
2026-05-31 16:27:22 +02:00
committed by Lala, Shahd
parent 65ddf55575
commit 4b2f3a256e
@@ -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(_) => ()