From af6d2c5aff056ce1b3994f1bce1a70530c763a2d Mon Sep 17 00:00:00 2001 From: Violeta Georgieva Date: Mon, 7 Oct 2024 22:17:19 +0300 Subject: [PATCH] CloseFuture is always indicating that the channel is closed --- .../main/java/reactor/netty/channel/ChannelOperations.java | 6 ++++++ 1 file changed, 6 insertions(+) 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 index 6f2cf1bef..bdbb99389 100644 --- 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;