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;