From 319a01f87982b8cf00a0b77839b69d161f32d606 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Fri, 22 Mar 2024 11:37:59 +0100
Subject: [PATCH] WIP:test: HandoverIT-POC - Clients are stopped after some
 time

---
 .../java/de/juplo/kafka/chat/backend/AbstractHandoverIT.java    | 2 +-
 1 file changed, 1 insertion(+), 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 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();
-- 
2.20.1