diff --git a/reactor-core/src/test/java/reactor/core/publisher/FluxGroupByTest.java b/reactor-core/src/test/java/reactor/core/publisher/FluxGroupByTest.java index 548c01f237..fdfeb524d7 100644 --- a/reactor-core/src/test/java/reactor/core/publisher/FluxGroupByTest.java +++ b/reactor-core/src/test/java/reactor/core/publisher/FluxGroupByTest.java @@ -74,7 +74,7 @@ void performanceOfContinuouslyCancellingGroups() throws Exception { latch.await(); assertThat(upstream).as("upstream and downstream consistent").hasValue(downstream.get()); - assertThat(downstream).as("order of magnitude").hasValueGreaterThan(9_999); + assertThat(downstream).as("order of magnitude").hasValueGreaterThan(30_000); } @Override