From 0f6505e32f795646a06d5fd6d490147d43ffdf0c Mon Sep 17 00:00:00 2001 From: Rossen Stoyanchev Date: Fri, 22 Jul 2016 12:42:35 -0400 Subject: [PATCH] Add timeout settings in SseIntegrationTests --- .../result/method/annotation/SseIntegrationTests.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/spring-web-reactive/src/test/java/org/springframework/web/reactive/result/method/annotation/SseIntegrationTests.java b/spring-web-reactive/src/test/java/org/springframework/web/reactive/result/method/annotation/SseIntegrationTests.java index cc1bf2b27a..caccb17881 100644 --- a/spring-web-reactive/src/test/java/org/springframework/web/reactive/result/method/annotation/SseIntegrationTests.java +++ b/spring-web-reactive/src/test/java/org/springframework/web/reactive/result/method/annotation/SseIntegrationTests.java @@ -87,7 +87,7 @@ public class SseIntegrationTests extends AbstractHttpHandlerIntegrationTests { TestSubscriber .subscribe(result) - .await() + .await(Duration.ofSeconds(5)) .assertValues("data:foo 0", "data:foo 1"); } @@ -104,7 +104,7 @@ public class SseIntegrationTests extends AbstractHttpHandlerIntegrationTests { TestSubscriber .subscribe(result) - .await() + .await(Duration.ofSeconds(5)) .assertValues("data:{\"name\":\"foo 0\"}data:{\"name\":\"foo 1\"}"); } @@ -120,7 +120,7 @@ public class SseIntegrationTests extends AbstractHttpHandlerIntegrationTests { TestSubscriber .subscribe(result) - .await() + .await(Duration.ofSeconds(5)) .assertValues( "id:0:bardata:foo", "id:1:bardata:foo"