From: Kai Moritz <kai@juplo.de>
Date: Fri, 22 Mar 2024 16:35:13 +0000 (+0100)
Subject: WIP:test: HandoverIT-POC - Excuting the Flu...
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=ac21311818f69ec0af8a5eb6307590fb28af6f2b;p=demos%2Fkafka%2Fchat

WIP:test: HandoverIT-POC - Excuting the Flu...
---

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 fd339411..717a0f0e 100644
--- a/src/test/java/de/juplo/kafka/chat/backend/TestWriter.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/TestWriter.java
@@ -41,9 +41,9 @@ public class TestWriter
             return i++;
           }
         })
-        .delayElements(Duration.ofMillis(ThreadLocalRandom.current().nextLong(500, 1500)))
         .map(i -> "Message #" + i)
         .flatMap(message -> sendMessage(chatRoom, message)
+            .delayElement(Duration.ofMillis(ThreadLocalRandom.current().nextLong(500, 1500)))
             .retryWhen(Retry.fixedDelay(10, Duration.ofSeconds(1))))
         .doOnNext(message ->
         {