add stayClosed
authorVladimir Krivosheev <vladimir.krivosheev@jetbrains.com>
Thu, 16 Jun 2016 12:05:03 +0000 (14:05 +0200)
committerVladimir Krivosheev <vladimir.krivosheev@jetbrains.com>
Thu, 16 Jun 2016 13:24:52 +0000 (15:24 +0200)
platform/platform-impl/src/org/jetbrains/io/ChannelRegistrar.java

index 8635b71598f2355edac1a72719054e0559cae07f..9d9e8f5d877ffbaaf61871c3626d36f58561809e 100644 (file)
@@ -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() {