diff --git a/spring-webmvc/src/test/java/org/springframework/web/servlet/function/DefaultAsyncServerResponseTests.java b/spring-webmvc/src/test/java/org/springframework/web/servlet/function/DefaultAsyncServerResponseTests.java index 1a4d53b92f14..49fbdaba9a13 100644 --- a/spring-webmvc/src/test/java/org/springframework/web/servlet/function/DefaultAsyncServerResponseTests.java +++ b/spring-webmvc/src/test/java/org/springframework/web/servlet/function/DefaultAsyncServerResponseTests.java @@ -39,17 +39,11 @@ void blockCompleted() { @Test void blockNotCompleted() { ServerResponse wrappee = ServerResponse.ok().build(); - CompletableFuture future = CompletableFuture.supplyAsync(() -> { - try { - Thread.sleep(500); - return wrappee; - } - catch (InterruptedException ex) { - throw new RuntimeException(ex); - } - }); + CompletableFuture future = new CompletableFuture<>(); AsyncServerResponse response = AsyncServerResponse.create(future); + new Thread(() -> future.complete(wrappee)).start(); + assertThat(response.block()).isSameAs(wrappee); }