projects
/
demos
/
kafka
/
chat
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
| inline |
side by side
(parent:
ca955f1
)
WIP:poc-setup
author
Kai Moritz
<kai@juplo.de>
Mon, 26 Feb 2024 14:13:51 +0000
(15:13 +0100)
committer
Kai Moritz
<kai@juplo.de>
Mon, 26 Feb 2024 14:13:51 +0000
(15:13 +0100)
src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java
patch
|
blob
|
history
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
35e261c
..
92306c7
100644
(file)
--- 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)