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