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 bdbb99389e..4a866fbd25 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 @@ -214,7 +214,9 @@ public void dispose() { if (!inbound.isDisposed()) { discard(); } - connection.dispose(); + if (!connection.isDisposed()) { + connection.dispose(); + } } @Override