Add missing timeout in web-reactive IntegrationTests

Author: bclozel

spring-web/src/test/java/org/springframework/http/server/reactive/FlushingIntegrationTests.java

@@ -32,6 +32,8 @@
 
 import static org.junit.Assume.assumeFalse;
 
+import java.time.Duration;
+
 /**
  * @author Sebastien Deleuze
  */
@@ -57,7 +59,7 @@ public void testFlushing() throws Exception {
 
 		TestSubscriber
 				.subscribe(result)
-				.await()
+				.await(Duration.ofSeconds(5))
 				.assertValues("data0data1");
 	}
 

spring-web/src/test/java/org/springframework/web/client/reactive/WebClientIntegrationTests.java

@@ -20,6 +20,7 @@
 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 void shouldGetErrorWhen404() throws Exception {
 
 		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 void shouldGetErrorWhen500() throws Exception {
 
 		TestSubscriber
 				.subscribe(result)
-				.await()
+				.await(Duration.ofSeconds(3))
 				.assertErrorWith(t -> {
 					assertThat(t, Matchers.instanceOf(WebServerErrorException.class));
 					WebServerErrorException exc = (WebServerErrorException) t;