From: Kai Moritz <kai@juplo.de>
Date: Fri, 22 Mar 2024 10:37:59 +0000 (+0100)
Subject: WIP:test: HandoverIT-POC - Clients are stopped after some time
X-Git-Url: https://juplo.de/gitweb/?a=commitdiff_plain;h=319a01f87982b8cf00a0b77839b69d161f32d606;p=demos%2Fkafka%2Fchat

WIP:test: HandoverIT-POC - Clients are stopped after some time
---

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 19d69049..7ab65f6f 100644
--- a/src/test/java/de/juplo/kafka/chat/backend/AbstractHandoverIT.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/AbstractHandoverIT.java
@@ -65,7 +65,7 @@ public abstract class AbstractHandoverIT
 
     Flux
         .fromArray(chatRooms)
-        .flatMap(chatRoom ->receiveMessages(chatRoom).take(2))
+        .flatMap(chatRoom ->receiveMessages(chatRoom).take(50))
         .doOnNext(message -> log.info("message: {}", message))
         .then()
         .block();