From: Kai Moritz <kai@juplo.de>
Date: Fri, 1 Mar 2024 19:44:32 +0000 (+0100)
Subject: WIP
X-Git-Tag: rebase--2024-03-03--11-38~7
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=9040f756b2c591244f82cd84bbcd2bc12bccdbf0;p=demos%2Fkafka%2Fchat

WIP
---

diff --git a/src/test/java/de/juplo/kafka/chat/backend/AbstractHandoverIT.java b/src/test/java/de/juplo/kafka/chat/backend/AbstractHandoverIT.java
index 0047ff01..261290a2 100644
--- a/src/test/java/de/juplo/kafka/chat/backend/AbstractHandoverIT.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/AbstractHandoverIT.java
@@ -61,7 +61,8 @@ public abstract class AbstractHandoverIT
         .run()
         .toFuture();
 
-    Thread.sleep(10000);
+    log.info("Sleepint for 3 seconds...");
+    Thread.sleep(3000);
 
     for (int i = 0; i < NUM_CLIENTS; i++)
     {
diff --git a/src/test/java/de/juplo/kafka/chat/backend/TestWriter.java b/src/test/java/de/juplo/kafka/chat/backend/TestWriter.java
index 5c6f7abd..9253ede8 100644
--- a/src/test/java/de/juplo/kafka/chat/backend/TestWriter.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/TestWriter.java
@@ -63,6 +63,7 @@ public class TestWriter
               user,
               e.getResponseBodyAsString(Charset.defaultCharset()));
         })
+        .takeUntil(message -> !running)
         .parallel()
         .runOn(Schedulers.parallel())
         .then();