From: Kai Moritz <kai@juplo.de>
Date: Sat, 3 Feb 2024 14:13:09 +0000 (+0100)
Subject: refactor: Renamed method in `InfoChannel` according to conventions
X-Git-Tag: rebase--2024-02-20--10-29~21
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=74501b5661b0a760cf2b45aa055120b0d20ef2e2;p=demos%2Fkafka%2Fchat

refactor: Renamed method in `InfoChannel` according to conventions
---

diff --git a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ConsumerTaskRunner.java b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ConsumerTaskRunner.java
index 983ebd37..c2c28014 100644
--- a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ConsumerTaskRunner.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ConsumerTaskRunner.java
@@ -21,7 +21,7 @@ public class ConsumerTaskRunner
   public void joinConsumerTasks() throws InterruptedException
   {
     dataChannelConsumerTaskExecutor.joinConsumerTaskJob();
-    while (infoChannel.loadInProgress())
+    while (infoChannel.isLoadInProgress())
     {
       log.info("Waiting for {} to finish loading...", infoChannel);
       Thread.sleep(1000);
diff --git a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/InfoChannel.java b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/InfoChannel.java
index cf4d03c2..3429d405 100644
--- a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/InfoChannel.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/InfoChannel.java
@@ -68,7 +68,7 @@ public class InfoChannel implements Runnable
   }
 
 
-  boolean loadInProgress()
+  boolean isLoadInProgress()
   {
     return IntStream
         .range(0, numShards)