From d548365dc468536c4d7fc00fda8309631bc2c35f Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Mon, 18 Oct 2021 18:23:11 +0200 Subject: [PATCH] Increased timeouts --- .../cloud/function/grpc/GrpcInteractionTests.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/spring-cloud-function-adapters/spring-cloud-function-grpc/src/test/java/org/springframework/cloud/function/grpc/GrpcInteractionTests.java b/spring-cloud-function-adapters/spring-cloud-function-grpc/src/test/java/org/springframework/cloud/function/grpc/GrpcInteractionTests.java index 2594eb5c5..f4d53c2c3 100644 --- a/spring-cloud-function-adapters/spring-cloud-function-grpc/src/test/java/org/springframework/cloud/function/grpc/GrpcInteractionTests.java +++ b/spring-cloud-function-adapters/spring-cloud-function-grpc/src/test/java/org/springframework/cloud/function/grpc/GrpcInteractionTests.java @@ -105,7 +105,7 @@ public class GrpcInteractionTests { Flux> clientResponseObserver = GrpcUtils.biStreaming("localhost", port, Flux.fromIterable(messages)); - List> results = clientResponseObserver.collectList().block(Duration.ofSeconds(5)); + List> results = clientResponseObserver.collectList().block(Duration.ofSeconds(10)); assertThat(results.size()).isEqualTo(3); assertThat(results.get(0).getPayload()).isEqualTo("\"RICKY\"".getBytes()); assertThat(results.get(1).getPayload()).isEqualTo("\"JULIEN\"".getBytes()); @@ -185,7 +185,7 @@ public class GrpcInteractionTests { Flux> reply = GrpcUtils.serverStream("localhost", port, message); - List> results = reply.collectList().block(Duration.ofSeconds(5)); + List> results = reply.collectList().block(Duration.ofSeconds(10)); assertThat(results.size()).isEqualTo(2); assertThat(results.get(0).getPayload()).isEqualTo("\"Ricky\"".getBytes()); assertThat(results.get(1).getPayload()).isEqualTo("\"RICKY\"".getBytes()); @@ -214,7 +214,7 @@ public class GrpcInteractionTests { GrpcUtils.biStreaming("localhost", port, Flux.fromIterable(messages)); try { - clientResponseObserver.collectList().block(Duration.ofSeconds(1)); + clientResponseObserver.collectList().block(Duration.ofSeconds(10)); fail(); } catch (Exception e) {