}
TestListener testListener = new TestListener(port, chatRooms);
- CompletableFuture<Void> testListenerFuture = testListener
+ testListener
.run()
- .toFuture();
+ .subscribe(message -> log.info(
+ "Received message: {}",
+ message));
- Thread.sleep(10000);
+ log.info("Sleeping for 3 seconds...");
+ Thread.sleep(3000);
for (int i = 0; i < NUM_CLIENTS; i++)
{
testWriters[i].running = false;
testWriterFutures[i].join();
+ log.info("Joined TestWriter {}", testWriters[i].user);
}
-
- testListener.running = false;
- testListenerFuture.join();
}
Mono<ChatRoomInfoTo> createChatRoom(String name)