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 0047ff0..261290a 100644 (file)
--- 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 5c6f7ab..9253ede 100644 (file)
--- 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();