diff --git a/reactor-netty-http/src/test/java/reactor/netty/http/client/Http2PoolTest.java b/reactor-netty-http/src/test/java/reactor/netty/http/client/Http2PoolTest.java index 25f99f4ff4..52b63c9f1e 100644 --- a/reactor-netty-http/src/test/java/reactor/netty/http/client/Http2PoolTest.java +++ b/reactor-netty-http/src/test/java/reactor/netty/http/client/Http2PoolTest.java @@ -32,6 +32,7 @@ import reactor.netty.internal.shaded.reactor.pool.PoolConfig; import reactor.netty.internal.shaded.reactor.pool.PooledRef; import reactor.test.StepVerifier; +import reactor.util.annotation.Nullable; import java.nio.charset.StandardCharsets; import java.time.Duration; @@ -852,7 +853,8 @@ void maxLifeTimeMaxConnectionsReachedWithCustomTimer() throws Exception { assertThat(latch.await(10, TimeUnit.SECONDS)).isTrue(); } - private void doMaxLifeTimeMaxConnectionsReached(BiFunction pendingAcquireTimer) throws Exception { + private void doMaxLifeTimeMaxConnectionsReached(@Nullable BiFunction pendingAcquireTimer) + throws Exception { PoolBuilder> poolBuilder = PoolBuilder.from(Mono.fromSupplier(() -> { Channel channel = new EmbeddedChannel(