From: Kai Moritz Date: Tue, 27 Feb 2024 10:48:49 +0000 (+0100) Subject: WIP:test: HandoverIT-POC - splitted up code into smaller classes -- ALIGN X-Git-Tag: rebase--2024-02-27--11-55~1 X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=ad723fbcbd352565b17ab65a68a08e9050ac6906;p=demos%2Fkafka%2Fchat WIP:test: HandoverIT-POC - splitted up code into smaller classes -- ALIGN --- 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 1eaf59a4..af5c9583 100644 --- a/src/test/java/de/juplo/kafka/chat/backend/AbstractHandoverIT.java +++ b/src/test/java/de/juplo/kafka/chat/backend/AbstractHandoverIT.java @@ -44,7 +44,7 @@ public abstract class HandoverIT "nerd"); IntStream .rangeClosed(1,100) - .mapToObj(i ->testClient.sendMessage(chatRoom, user, "Message #" + i)) + .mapToObj(i ->testClient.sendMessage(chatRoom, "Message #" + i)) .map(result -> result .map(MessageTo::toString) .retryWhen(Retry.fixedDelay(10, Duration.ofSeconds(1)))