diff --git a/spring-cloud-function-grpc/src/test/java/org/springframework/cloud/function/grpc/GrpcInteractionTests.java b/spring-cloud-function-grpc/src/test/java/org/springframework/cloud/function/grpc/GrpcInteractionTests.java index 847a2124d..7bf312a2c 100644 --- a/spring-cloud-function-grpc/src/test/java/org/springframework/cloud/function/grpc/GrpcInteractionTests.java +++ b/spring-cloud-function-grpc/src/test/java/org/springframework/cloud/function/grpc/GrpcInteractionTests.java @@ -102,7 +102,7 @@ public class GrpcInteractionTests { Flux> clientResponseObserver = GrpcUtils.biStreaming("localhost", FunctionGrpcProperties.GRPC_PORT, Flux.fromIterable(messages)); - List> results = clientResponseObserver.collectList().block(Duration.ofSeconds(1)); + List> results = clientResponseObserver.collectList().block(Duration.ofSeconds(5)); assertThat(results.size()).isEqualTo(3); assertThat(results.get(0).getPayload()).isEqualTo("\"RICKY\"".getBytes()); assertThat(results.get(1).getPayload()).isEqualTo("\"JULIEN\"".getBytes());