use NettyLeakDetectorExtension

Author: sullis

build.gradle

@@ -130,6 +130,7 @@ ext {
 	awaitilityVersion = '4.2.2'
 	hoverflyJavaVersion = '0.19.1'
 	tomcatVersion = '9.0.99'
+	nettyLeakDetectorJunitExtensionVersion = "0.0.6"
 	boringSslVersion = '2.0.70.Final'
 	junitVersion = '5.11.4'
 	junitPlatformLauncherVersion = '1.11.4'

reactor-netty-core/build.gradle

@@ -135,6 +135,7 @@ dependencies {
 	testImplementation "org.awaitility:awaitility:$awaitilityVersion"
 	testImplementation "org.junit.jupiter:junit-jupiter-api:$junitVersion"
 	testImplementation "org.junit.jupiter:junit-jupiter-params:$junitVersion"
+	testImplementation "io.github.nettyplus:netty-leak-detector-junit-extension:$nettyLeakDetectorJunitExtensionVersion"
 	testImplementation "org.mockito:mockito-core:$mockitoVersion"
 	testImplementation "ch.qos.logback:logback-classic:$logbackVersion"
 	testImplementation "io.projectreactor.tools:blockhound-junit-platform:$blockHoundVersion"

reactor-netty-core/src/test/java/reactor/netty/ByteBufFluxTest.java

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2017-2022 VMware, Inc. or its affiliates, All Rights Reserved.
+ * Copyright (c) 2017-2024 VMware, Inc. or its affiliates, All Rights Reserved.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -15,10 +15,12 @@
  */
 package reactor.netty;
 
+import io.github.nettyplus.leakdetector.junit.NettyLeakDetectorExtension;
 import io.netty.buffer.ByteBuf;
 import org.junit.jupiter.api.AfterAll;
 import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
 import org.reactivestreams.Publisher;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
@@ -38,6 +40,7 @@
 
 import static org.assertj.core.api.Assertions.assertThat;
 
+@ExtendWith(NettyLeakDetectorExtension.class)
 class ByteBufFluxTest {
 
 	private static File temporaryDirectory;

reactor-netty-core/src/test/java/reactor/netty/ByteBufMonoTest.java

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2020-2021 VMware, Inc. or its affiliates, All Rights Reserved.
+ * Copyright (c) 2020-2024 VMware, Inc. or its affiliates, All Rights Reserved.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -15,7 +15,9 @@
  */
 package reactor.netty;
 
+import io.github.nettyplus.leakdetector.junit.NettyLeakDetectorExtension;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
 import org.reactivestreams.Publisher;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
@@ -24,6 +26,7 @@
 import java.nio.charset.Charset;
 import java.time.Duration;
 
+@ExtendWith(NettyLeakDetectorExtension.class)
 class ByteBufMonoTest {
 
 	@Test

reactor-netty-core/src/test/java/reactor/netty/ConnectionTest.java

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2017-2023 VMware, Inc. or its affiliates, All Rights Reserved.
+ * Copyright (c) 2017-2024 VMware, Inc. or its affiliates, All Rights Reserved.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -20,6 +20,7 @@
 import java.util.concurrent.atomic.AtomicReference;
 import java.util.function.BiConsumer;
 
+import io.github.nettyplus.leakdetector.junit.NettyLeakDetectorExtension;
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelHandler;
 import io.netty.channel.ChannelHandlerAdapter;
@@ -30,6 +31,7 @@
 import io.netty.handler.codec.http.websocketx.Utf8FrameValidator;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
 import reactor.core.Disposable;
 import reactor.core.publisher.Mono;
 
@@ -42,6 +44,7 @@
  * @author Simon Baslé
  * @author Violeta Georgieva
  */
+@ExtendWith(NettyLeakDetectorExtension.class)
 class ConnectionTest {
 
 	static final BiConsumer<? super ChannelHandlerContext, Object> ADD_EXTRACTOR = ChannelHandlerContext::fireChannelRead;

reactor-netty-core/src/test/java/reactor/netty/NettyOutboundTest.java

@@ -33,6 +33,7 @@
 import java.util.function.Predicate;
 import javax.net.ssl.SSLException;
 
+import io.github.nettyplus.leakdetector.junit.NettyLeakDetectorExtension;
 import io.netty.buffer.ByteBuf;
 import io.netty.buffer.ByteBufAllocator;
 import io.netty.channel.ChannelFuture;
@@ -52,11 +53,13 @@
 import io.netty.util.ReferenceCountUtil;
 import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
 import org.reactivestreams.Publisher;
 import reactor.core.publisher.Mono;
 
 import static org.assertj.core.api.Assertions.assertThat;
 
+@ExtendWith(NettyLeakDetectorExtension.class)
 class NettyOutboundTest {
 
 	static SelfSignedCertificate ssc;

reactor-netty-core/src/test/java/reactor/netty/ReactorNettyTest.java

@@ -15,6 +15,7 @@
  */
 package reactor.netty;
 
+import io.github.nettyplus.leakdetector.junit.NettyLeakDetectorExtension;
 import io.netty.channel.AbstractChannel;
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelConfig;
@@ -24,6 +25,7 @@
 import io.netty.channel.embedded.EmbeddedChannel;
 import org.jspecify.annotations.Nullable;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
 
 import java.net.InetSocketAddress;
 import java.net.SocketAddress;
@@ -35,6 +37,7 @@
  *
  * @author Violeta Georgieva
  */
+@ExtendWith(NettyLeakDetectorExtension.class)
 class ReactorNettyTest {
 
 	/*

reactor-netty-http/build.gradle

@@ -138,6 +138,7 @@ dependencies {
 
 	testImplementation "org.mockito:mockito-core:$mockitoVersion"
 	testImplementation "io.specto:hoverfly-java-junit5:$hoverflyJavaVersion"
+	testImplementation "io.github.nettyplus:netty-leak-detector-junit-extension:$nettyLeakDetectorJunitExtensionVersion"
 	testImplementation "org.apache.tomcat.embed:tomcat-embed-core:$tomcatVersion"
 	testImplementation "io.projectreactor:reactor-test:$testAddonVersion"
 	testImplementation "org.assertj:assertj-core:$assertJVersion"

reactor-netty-http/src/test/java/reactor/netty/BaseHttpTest.java

@@ -15,8 +15,10 @@
  */
 package reactor.netty;
 
+import io.github.nettyplus.leakdetector.junit.NettyLeakDetectorExtension;
 import org.jspecify.annotations.Nullable;
 import org.junit.jupiter.api.AfterEach;
+import org.junit.jupiter.api.extension.ExtendWith;
 import org.junit.jupiter.params.provider.Arguments;
 import reactor.netty.http.HttpProtocol;
 import reactor.netty.http.client.HttpClient;
@@ -34,6 +36,7 @@
  * @author Violeta Georgieva
  * @since 1.0.3
  */
+@ExtendWith(NettyLeakDetectorExtension.class)
 public class BaseHttpTest {
 
 	protected DisposableServer disposableServer;