From 313a1ff6a5a6a3ce2c9718a8f71965c441c937f7 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Fri, 15 Sep 2023 20:58:52 +0200
Subject: [PATCH] FIX

---
 .../implementation/kafka/DataChannel.java     | 21 +++++++++----------
 1 file changed, 10 insertions(+), 11 deletions(-)

diff --git a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/DataChannel.java b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/DataChannel.java
index e42ea9f2..de681945 100644
--- a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/DataChannel.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/DataChannel.java
@@ -299,16 +299,15 @@ public class DataChannel implements Runnable, ConsumerRebalanceListener
     return infoChannel
         .getChatRoomInfo(id)
         .map(chatRoomInfo ->
-        {
-          if (chatRoomInfo == null) return null;
-          return chatRoomData[shard].computeIfAbsent(
-              id,
-              (chatRoomId) ->
-              {
-                log.info("Creating ChatRoom {} with buffer-size {}", chatRoomId, bufferSize);
-                KafkaChatMessageService service = new KafkaChatMessageService(this, chatRoomId);
-                return new ChatRoomData(clock, service, bufferSize);
-              });
-        });
+          chatRoomInfo == null
+              ? null
+              : chatRoomData[shard].computeIfAbsent(
+                  id,
+                  (chatRoomId) ->
+                  {
+                    log.info("Creating ChatRoom {} with buffer-size {}", chatRoomId, bufferSize);
+                    KafkaChatMessageService service = new KafkaChatMessageService(this, chatRoomId);
+                    return new ChatRoomData(clock, service, bufferSize);
+                  }));
   }
 }
-- 
2.20.1