Class DelegatingEventLoopGroup

    • Constructor Detail

      • DelegatingEventLoopGroup

        public DelegatingEventLoopGroup()
    • Method Detail

      • delegate

        protected abstract io.netty.channel.EventLoopGroup delegate()
      • isShuttingDown

        public boolean isShuttingDown()
        Specified by:
        isShuttingDown in interface io.netty.util.concurrent.EventExecutorGroup
      • shutdownGracefully

        public io.netty.util.concurrent.Future<?> shutdownGracefully()
        Specified by:
        shutdownGracefully in interface io.netty.util.concurrent.EventExecutorGroup
      • shutdownGracefully

        public io.netty.util.concurrent.Future<?> shutdownGracefully​(long quietPeriod,
                                                                     long timeout,
                                                                     TimeUnit unit)
        Specified by:
        shutdownGracefully in interface io.netty.util.concurrent.EventExecutorGroup
      • terminationFuture

        public io.netty.util.concurrent.Future<?> terminationFuture()
        Specified by:
        terminationFuture in interface io.netty.util.concurrent.EventExecutorGroup
      • shutdown

        public void shutdown()
        Specified by:
        shutdown in interface io.netty.util.concurrent.EventExecutorGroup
        Specified by:
        shutdown in interface ExecutorService
      • shutdownNow

        public List<Runnable> shutdownNow()
        Specified by:
        shutdownNow in interface io.netty.util.concurrent.EventExecutorGroup
        Specified by:
        shutdownNow in interface ExecutorService
      • next

        public io.netty.channel.EventLoop next()
        Specified by:
        next in interface io.netty.util.concurrent.EventExecutorGroup
        Specified by:
        next in interface io.netty.channel.EventLoopGroup
      • iterator

        public Iterator<io.netty.util.concurrent.EventExecutor> iterator()
        Specified by:
        iterator in interface io.netty.util.concurrent.EventExecutorGroup
        Specified by:
        iterator in interface Iterable<io.netty.util.concurrent.EventExecutor>
      • submit

        public io.netty.util.concurrent.Future<?> submit​(Runnable task)
        Specified by:
        submit in interface io.netty.util.concurrent.EventExecutorGroup
        Specified by:
        submit in interface ExecutorService
      • submit

        public <T> io.netty.util.concurrent.Future<T> submit​(Runnable task,
                                                             T result)
        Specified by:
        submit in interface io.netty.util.concurrent.EventExecutorGroup
        Specified by:
        submit in interface ExecutorService
      • submit

        public <T> io.netty.util.concurrent.Future<T> submit​(Callable<T> task)
        Specified by:
        submit in interface io.netty.util.concurrent.EventExecutorGroup
        Specified by:
        submit in interface ExecutorService
      • schedule

        public io.netty.util.concurrent.ScheduledFuture<?> schedule​(Runnable command,
                                                                    long delay,
                                                                    TimeUnit unit)
        Specified by:
        schedule in interface io.netty.util.concurrent.EventExecutorGroup
        Specified by:
        schedule in interface ScheduledExecutorService
      • schedule

        public <V> io.netty.util.concurrent.ScheduledFuture<V> schedule​(Callable<V> callable,
                                                                        long delay,
                                                                        TimeUnit unit)
        Specified by:
        schedule in interface io.netty.util.concurrent.EventExecutorGroup
        Specified by:
        schedule in interface ScheduledExecutorService
      • scheduleAtFixedRate

        public io.netty.util.concurrent.ScheduledFuture<?> scheduleAtFixedRate​(Runnable command,
                                                                               long initialDelay,
                                                                               long period,
                                                                               TimeUnit unit)
        Specified by:
        scheduleAtFixedRate in interface io.netty.util.concurrent.EventExecutorGroup
        Specified by:
        scheduleAtFixedRate in interface ScheduledExecutorService
      • scheduleWithFixedDelay

        public io.netty.util.concurrent.ScheduledFuture<?> scheduleWithFixedDelay​(Runnable command,
                                                                                  long initialDelay,
                                                                                  long delay,
                                                                                  TimeUnit unit)
        Specified by:
        scheduleWithFixedDelay in interface io.netty.util.concurrent.EventExecutorGroup
        Specified by:
        scheduleWithFixedDelay in interface ScheduledExecutorService
      • register

        public io.netty.channel.ChannelFuture register​(io.netty.channel.Channel channel)
        Specified by:
        register in interface io.netty.channel.EventLoopGroup
      • register

        public io.netty.channel.ChannelFuture register​(io.netty.channel.ChannelPromise promise)
        Specified by:
        register in interface io.netty.channel.EventLoopGroup
      • register

        public io.netty.channel.ChannelFuture register​(io.netty.channel.Channel channel,
                                                       io.netty.channel.ChannelPromise promise)
        Specified by:
        register in interface io.netty.channel.EventLoopGroup