Skip to content

Commit

Permalink
Mark method param as Nullable (#2326)
Browse files Browse the repository at this point in the history
  • Loading branch information
violetagg committed Jun 24, 2022
1 parent 86cb1db commit 06dc577
Showing 1 changed file with 3 additions and 1 deletion.
Expand Up @@ -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;
Expand Down Expand Up @@ -852,7 +853,8 @@ void maxLifeTimeMaxConnectionsReachedWithCustomTimer() throws Exception {
assertThat(latch.await(10, TimeUnit.SECONDS)).isTrue();
}

private void doMaxLifeTimeMaxConnectionsReached(BiFunction<Runnable, Duration, Disposable> pendingAcquireTimer) throws Exception {
private void doMaxLifeTimeMaxConnectionsReached(@Nullable BiFunction<Runnable, Duration, Disposable> pendingAcquireTimer)
throws Exception {
PoolBuilder<Connection, PoolConfig<Connection>> poolBuilder =
PoolBuilder.from(Mono.fromSupplier(() -> {
Channel channel = new EmbeddedChannel(
Expand Down

0 comments on commit 06dc577

Please sign in to comment.