From 252851de1cd715f797847e0660ee501c3a77237e Mon Sep 17 00:00:00 2001 From: Janis Eccarius Date: Sun, 31 May 2026 16:27:22 +0200 Subject: [PATCH] fix(store): replace null check with Option for stream messages --- .../de/nowchess/store/redis/GameWritebackStreamListener.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/modules/store/src/main/scala/de/nowchess/store/redis/GameWritebackStreamListener.scala b/modules/store/src/main/scala/de/nowchess/store/redis/GameWritebackStreamListener.scala index 519ae2d..1bce103 100644 --- a/modules/store/src/main/scala/de/nowchess/store/redis/GameWritebackStreamListener.scala +++ b/modules/store/src/main/scala/de/nowchess/store/redis/GameWritebackStreamListener.scala @@ -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(_) => ()