From bc1727e9971a214f8b562f78be3efe7ca9ae2bd3 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Fri, 1 Sep 2023 19:40:12 +0200
Subject: [PATCH] WIP
---
.../juplo/kafka/chat/backend/domain/ChatHomeTestBase.java | 8 ++++----
.../chat/backend/domain/ChatHomeWithShardsTestBase.java | 4 ++--
2 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/src/test/java/de/juplo/kafka/chat/backend/domain/ChatHomeTestBase.java b/src/test/java/de/juplo/kafka/chat/backend/domain/ChatHomeTestBase.java
index 4bf11899..3164de56 100644
--- a/src/test/java/de/juplo/kafka/chat/backend/domain/ChatHomeTestBase.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/domain/ChatHomeTestBase.java
@@ -29,8 +29,8 @@ public class ChatHomeTestBase
UUID chatRoomId = UUID.fromString("5c73531c-6fc4-426c-adcb-afc5c140a0f7");
// When
- Mono<ChatRoom> mono = chatHome
- .getChatRoom(chatRoomId)
+ Mono<ChatRoom> mono = Mono
+ .defer(() -> chatHome.getChatRoom(chatRoomId))
.log("testGetExistingChatroom")
.retryWhen(Retry
.backoff(5, Duration.ofSeconds(1))
@@ -48,8 +48,8 @@ public class ChatHomeTestBase
UUID chatRoomId = UUID.fromString("7f59ec77-832e-4a17-8d22-55ef46242c17");
// When
- Mono<ChatRoom> mono = chatHome
- .getChatRoom(chatRoomId)
+ Mono<ChatRoom> mono = Mono
+ .defer(() -> chatHome.getChatRoom(chatRoomId))
.log("testGetNonExistentChatroom")
.retryWhen(Retry
.backoff(5, Duration.ofSeconds(1))
diff --git a/src/test/java/de/juplo/kafka/chat/backend/domain/ChatHomeWithShardsTestBase.java b/src/test/java/de/juplo/kafka/chat/backend/domain/ChatHomeWithShardsTestBase.java
index 85e187b2..a89da6b9 100644
--- a/src/test/java/de/juplo/kafka/chat/backend/domain/ChatHomeWithShardsTestBase.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/domain/ChatHomeWithShardsTestBase.java
@@ -26,8 +26,8 @@ public class ChatHomeWithShardsTestBase extends ChatHomeTestBase
UUID chatRoomId = UUID.fromString("4e7246a6-29ae-43ea-b56f-669c3481ac19");
// When
- Mono<ChatRoom> mono = chatHome
- .getChatRoom(chatRoomId)
+ Mono<ChatRoom> mono = Mono
+ .defer(() -> chatHome.getChatRoom(chatRoomId))
.log("testGetChatroomForNotOwnedShard")
.retryWhen(Retry
.backoff(5, Duration.ofSeconds(1))
--
2.20.1