From 9040f756b2c591244f82cd84bbcd2bc12bccdbf0 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Fri, 1 Mar 2024 20:44:32 +0100 Subject: [PATCH] WIP --- .../java/de/juplo/kafka/chat/backend/AbstractHandoverIT.java | 3 ++- src/test/java/de/juplo/kafka/chat/backend/TestWriter.java | 1 + 2 files changed, 3 insertions(+), 1 deletion(-) 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(); -- 2.20.1