From 6e54ed0df1b3a99f2d0a5f8536df2f97c3537547 Mon Sep 17 00:00:00 2001 From: Brian Clozel Date: Fri, 22 Jul 2016 21:37:51 +0200 Subject: [PATCH] Add missing timeout in web-reactive IntegrationTests --- .../http/server/reactive/FlushingIntegrationTests.java | 4 +++- .../web/client/reactive/WebClientIntegrationTests.java | 5 +++-- 2 files changed, 6 insertions(+), 3 deletions(-) diff --git a/spring-web/src/test/java/org/springframework/http/server/reactive/FlushingIntegrationTests.java b/spring-web/src/test/java/org/springframework/http/server/reactive/FlushingIntegrationTests.java index d97bc276e7..5b12b700f9 100644 --- a/spring-web/src/test/java/org/springframework/http/server/reactive/FlushingIntegrationTests.java +++ b/spring-web/src/test/java/org/springframework/http/server/reactive/FlushingIntegrationTests.java @@ -32,6 +32,8 @@ import org.springframework.web.client.reactive.WebClient; import static org.junit.Assume.assumeFalse; +import java.time.Duration; + /** * @author Sebastien Deleuze */ @@ -57,7 +59,7 @@ public class FlushingIntegrationTests extends AbstractHttpHandlerIntegrationTest TestSubscriber .subscribe(result) - .await() + .await(Duration.ofSeconds(5)) .assertValues("data0data1"); } diff --git a/spring-web/src/test/java/org/springframework/web/client/reactive/WebClientIntegrationTests.java b/spring-web/src/test/java/org/springframework/web/client/reactive/WebClientIntegrationTests.java index fded9b3013..f6c095124e 100644 --- a/spring-web/src/test/java/org/springframework/web/client/reactive/WebClientIntegrationTests.java +++ b/spring-web/src/test/java/org/springframework/web/client/reactive/WebClientIntegrationTests.java @@ -20,6 +20,7 @@ import static org.junit.Assert.*; import static org.springframework.web.client.reactive.ClientWebRequestBuilders.*; import static org.springframework.web.client.reactive.ResponseExtractors.*; +import java.time.Duration; import java.util.function.Consumer; import okhttp3.HttpUrl; @@ -291,7 +292,7 @@ public class WebClientIntegrationTests { TestSubscriber .subscribe(result) - .await() + .await(Duration.ofSeconds(3)) .assertErrorWith(t -> { assertThat(t, Matchers.instanceOf(WebClientErrorException.class)); WebClientErrorException exc = (WebClientErrorException) t; @@ -324,7 +325,7 @@ public class WebClientIntegrationTests { TestSubscriber .subscribe(result) - .await() + .await(Duration.ofSeconds(3)) .assertErrorWith(t -> { assertThat(t, Matchers.instanceOf(WebServerErrorException.class)); WebServerErrorException exc = (WebServerErrorException) t;