CloseFuture is always indicating that the channel is closed

reactor · Oct 8, 2024 · af6d2c5 · af6d2c5
1 parent d3bbcb8
commit af6d2c5
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/reactor-netty-core/src/main/java/reactor/netty/channel/ChannelOperations.java b/reactor-netty-core/src/main/java/reactor/netty/channel/ChannelOperations.java
@@ -28,6 +28,7 @@
 import io.netty.channel.AbstractChannel;
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelConfig;
+import io.netty.channel.ChannelFuture;
 import io.netty.channel.ChannelHandler;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.ChannelMetadata;
@@ -705,6 +706,11 @@ static final class DisposedChannel extends AbstractChannel {
 			this.remoteAddress = copy.remoteAddress();
 		}
 
+		@Override
+		public ChannelFuture closeFuture() {
+			return newSucceededFuture();
+		}
+
 		@Override
 		public ChannelConfig config() {
 			return config;