From 384f57a61de4266583bc7522763285eae248afe0 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sun, 5 May 2024 14:11:37 +0200
Subject: [PATCH] WIP

---
 .../juplo/kafka/wordcount/recorder/ApplicationTests.java   | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/src/test/java/de/juplo/kafka/wordcount/recorder/ApplicationTests.java b/src/test/java/de/juplo/kafka/wordcount/recorder/ApplicationTests.java
index 0a70993..19bb8f5 100644
--- a/src/test/java/de/juplo/kafka/wordcount/recorder/ApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/wordcount/recorder/ApplicationTests.java
@@ -13,11 +13,13 @@ import org.springframework.http.MediaType;
 import org.springframework.kafka.annotation.KafkaListener;
 import org.springframework.kafka.test.context.EmbeddedKafka;
 import org.springframework.test.web.servlet.MockMvc;
+import org.springframework.test.web.servlet.MvcResult;
 import org.springframework.util.LinkedMultiValueMap;
 import org.springframework.util.MultiValueMap;
 
 import static de.juplo.kafka.wordcount.recorder.ApplicationTests.PARTITIONS;
 import static de.juplo.kafka.wordcount.recorder.ApplicationTests.TOPIC_OUT;
+import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.asyncDispatch;
 import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.post;
 import static org.springframework.test.web.servlet.result.MockMvcResultHandlers.print;
 import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.jsonPath;
@@ -52,10 +54,13 @@ class ApplicationTests
 	@Test
 	void userMessagesAreExceptedAndSentToKafka() throws Exception
 	{
-		mockMvc
+		MvcResult result = mockMvc
 				.perform(post("/{user}", USER)
 						.contentType(MediaType.TEXT_PLAIN)
 						.content(SENTENCE))
+				.andReturn();
+
+		mockMvc.perform(asyncDispatch(result))
 				.andDo(print())
 				.andExpect(status().isOk())
 				.andExpect(jsonPath("$.username").value(USER))
-- 
2.20.1