From f320c3ef4a8e963b52f3153b3d2eafa83cce3c66 Mon Sep 17 00:00:00 2001 From: Vladimir Krivosheev Date: Thu, 16 Jun 2016 14:05:03 +0200 Subject: [PATCH] add stayClosed --- .../platform-impl/src/org/jetbrains/io/ChannelRegistrar.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/platform/platform-impl/src/org/jetbrains/io/ChannelRegistrar.java b/platform/platform-impl/src/org/jetbrains/io/ChannelRegistrar.java index 8635b71598f2..9d9e8f5d877f 100644 --- a/platform/platform-impl/src/org/jetbrains/io/ChannelRegistrar.java +++ b/platform/platform-impl/src/org/jetbrains/io/ChannelRegistrar.java @@ -31,7 +31,7 @@ import java.util.concurrent.TimeUnit; public final class ChannelRegistrar extends ChannelInboundHandlerAdapter { private static final Logger LOG = Logger.getInstance(ChannelRegistrar.class); - private final ChannelGroup openChannels = new DefaultChannelGroup(ImmediateEventExecutor.INSTANCE); + private final ChannelGroup openChannels = new DefaultChannelGroup(ImmediateEventExecutor.INSTANCE, true); private boolean isEventLoopGroupOwner; public boolean isEmpty() {