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) {