From 761c2632313046a87f6046409f956a6dc98896ef Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sun, 3 Mar 2024 11:21:06 +0100 Subject: [PATCH] DIRTYFIX:subscribe --- .../de/juplo/kafka/chat/backend/TestListener.java | 15 +-------------- 1 file changed, 1 insertion(+), 14 deletions(-) diff --git a/src/test/java/de/juplo/kafka/chat/backend/TestListener.java b/src/test/java/de/juplo/kafka/chat/backend/TestListener.java index f01e9b57..b7a5b850 100644 --- a/src/test/java/de/juplo/kafka/chat/backend/TestListener.java +++ b/src/test/java/de/juplo/kafka/chat/backend/TestListener.java @@ -12,7 +12,6 @@ import org.springframework.http.codec.ServerSentEvent; import org.springframework.web.reactive.function.client.WebClient; import reactor.core.publisher.Flux; import reactor.core.publisher.Mono; -import reactor.core.scheduler.Schedulers; import java.util.*; @@ -43,18 +42,8 @@ public class TestListener { return Mono.error(e); } - }) - .doOnNext(message -> - { - list.add(message); - log.info( - "Received a message from chat-room {}: {}", - chatRoom.getName(), - message); }); - }) - .takeUntil(message -> !running) - .doOnComplete(() -> log.info("TestListener is done")); + }); } Flux> receiveMessages(ChatRoomInfoTo chatRoom) @@ -76,8 +65,6 @@ public class TestListener final Map> receivedMessages = new HashMap<>(); - volatile boolean running = true; - TestListener(Integer port, ChatRoomInfoTo[] chatRooms) { -- 2.20.1