From f5522949f320a08533873ca14c6c7dd056693175 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Fri, 31 Jul 2020 09:59:09 -0400 Subject: [PATCH] WebFluxDslTests: wait for reply for 10 seconds --- .../webflux/dsl/WebFluxDslTests.java | 17 +++++++---------- 1 file changed, 7 insertions(+), 10 deletions(-) diff --git a/spring-integration-webflux/src/test/java/org/springframework/integration/webflux/dsl/WebFluxDslTests.java b/spring-integration-webflux/src/test/java/org/springframework/integration/webflux/dsl/WebFluxDslTests.java index 5e0cd1d46d..5f5c5ddcc3 100644 --- a/spring-integration-webflux/src/test/java/org/springframework/integration/webflux/dsl/WebFluxDslTests.java +++ b/spring-integration-webflux/src/test/java/org/springframework/integration/webflux/dsl/WebFluxDslTests.java @@ -140,7 +140,7 @@ public class WebFluxDslTests { WebTestClient.bindToApplicationContext(this.wac) .apply(SecurityMockServerConfigurers.springSecurity()) .configureClient() - .responseTimeout(Duration.ofSeconds(600)) + .responseTimeout(Duration.ofSeconds(10)) .build(); } @@ -249,15 +249,12 @@ public class WebFluxDslTests { @Test public void testSse() { - Flux responseBody = - this.webTestClient.get().uri("/sse") - .headers(headers -> headers.setBasicAuth("guest", "guest")) - .exchange() - .returnResult(String.class) - .getResponseBody(); - - StepVerifier - .create(responseBody) + this.webTestClient.get().uri("/sse") + .headers(headers -> headers.setBasicAuth("guest", "guest")) + .exchange() + .returnResult(String.class) + .getResponseBody() + .as(StepVerifier::create) .expectNext("foo", "bar", "baz") .verifyComplete(); }