From 252c385469bf59e75757d5cd1946e4cc4e57f7f5 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Fri, 1 Mar 2024 13:48:57 +0100
Subject: [PATCH] test: HandoverIT-POC - Renamed `TestClient` to `TestWriter`
-- ALIGN
---
.../de/juplo/kafka/chat/backend/AbstractHandoverIT.java | 8 ++++----
src/test/java/de/juplo/kafka/chat/backend/TestWriter.java | 4 ++--
2 files changed, 6 insertions(+), 6 deletions(-)
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 b67a2db9..aaea973a 100644
--- a/src/test/java/de/juplo/kafka/chat/backend/AbstractHandoverIT.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/AbstractHandoverIT.java
@@ -47,19 +47,19 @@ public abstract class AbstractHandoverIT
.toStream()
.toArray(size -> new ChatRoomInfoTo[size]);
- TestClient[] testClients = Flux
+ TestWriter[] testWriters = Flux
.fromStream(IntStream.range(0, NUM_CLIENTS).mapToObj(i -> "user-" + Integer.toString(i)))
- .map(i -> new TestClient(
+ .map(i -> new TestWriter(
containers.haproxy.getMappedPort(8400),
chatRooms,
i))
.doOnNext(testClient -> executorService.execute(testClient))
.toStream()
- .toArray(size -> new TestClient[size]);
+ .toArray(size -> new TestWriter[size]);
Thread.sleep(10000);
Arrays
- .stream(testClients)
+ .stream(testWriters)
.forEach(testClient -> testClient.running = false);
Flux
diff --git a/src/test/java/de/juplo/kafka/chat/backend/TestWriter.java b/src/test/java/de/juplo/kafka/chat/backend/TestWriter.java
index 0d54600d..076376e8 100644
--- a/src/test/java/de/juplo/kafka/chat/backend/TestWriter.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/TestWriter.java
@@ -16,7 +16,7 @@ import java.util.concurrent.ThreadLocalRandom;
@Slf4j
-public class TestClient implements Runnable
+public class TestWriter implements Runnable
{
@Override
public void run()
@@ -86,7 +86,7 @@ public class TestClient implements Runnable
volatile boolean running = true;
- TestClient(Integer port, ChatRoomInfoTo[] chatRooms, String username)
+ TestWriter(Integer port, ChatRoomInfoTo[] chatRooms, String username)
{
webClient = WebClient.create("http://localhost:" + port);
this.chatRooms = chatRooms;
--
2.20.1