From 03a4825d54a803e6a6ed1e3559ccd2c366b374a3 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Mon, 26 Feb 2024 15:13:51 +0100
Subject: [PATCH] WIP:poc-setup

---
 .../java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java b/src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java
index 35e261c7..92306c70 100644
--- a/src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java
@@ -46,7 +46,13 @@ class KafkaHandoverIT extends AbstractHandoverIT
             .block())
         .forEach(result -> log.info("{}", result));
 
-    receiveMessages(chatRoom).subscribe(message -> log.info("message: {}", message));
+    Long count = receiveMessages(chatRoom)
+        .doOnNext(message -> log.info("message: {}", message))
+        .count()
+        .block();
+    log.info("Received {} messages", count);
+
+    Thread.sleep(1000);
   }
 
   Mono<ChatRoomInfoTo> createChatRoom(String name)
-- 
2.20.1