EventLoopGroupProxy

class EventLoopGroupProxy(val channel: KClass<out ServerSocketChannel>, group: EventLoopGroup) : EventLoopGroup

Transparently allows for the creation of EventLoopGroup's utilising the optimal implementation for a given operating system, subject to availability, or falling back to NioEventLoopGroup if none is available.

Constructors

Link copied to clipboard
constructor(channel: KClass<out ServerSocketChannel>, group: EventLoopGroup)

Types

Link copied to clipboard
object Companion

Properties

Link copied to clipboard
val channel: KClass<out ServerSocketChannel>

Functions

Link copied to clipboard
open override fun awaitTermination(p0: Long, p1: TimeUnit): Boolean
Link copied to clipboard
open override fun execute(p0: Runnable)
Link copied to clipboard
open fun forEach(p0: Consumer<in EventExecutor>)
Link copied to clipboard
open override fun <T : Any> invokeAll(p0: MutableCollection<out Callable<T>>): MutableList<Future<T>>
open override fun <T : Any> invokeAll(p0: MutableCollection<out Callable<T>>, p1: Long, p2: TimeUnit): MutableList<Future<T>>
Link copied to clipboard
open override fun <T : Any> invokeAny(p0: MutableCollection<out Callable<T>>): T
open override fun <T : Any> invokeAny(p0: MutableCollection<out Callable<T>>, p1: Long, p2: TimeUnit): T
Link copied to clipboard
open override fun isShutdown(): Boolean
Link copied to clipboard
open override fun isShuttingDown(): Boolean
Link copied to clipboard
open override fun isTerminated(): Boolean
Link copied to clipboard
open operator override fun iterator(): MutableIterator<EventExecutor>
Link copied to clipboard
open operator override fun next(): EventLoop
Link copied to clipboard
open override fun register(p0: Channel): ChannelFuture
open override fun register(p0: ChannelPromise): ChannelFuture
open override fun register(p0: Channel, p1: ChannelPromise): ChannelFuture
Link copied to clipboard
open override fun schedule(p0: Runnable, p1: Long, p2: TimeUnit): ScheduledFuture<*>
open override fun <V : Any> schedule(p0: Callable<V>, p1: Long, p2: TimeUnit): ScheduledFuture<V>
Link copied to clipboard
open override fun scheduleAtFixedRate(p0: Runnable, p1: Long, p2: Long, p3: TimeUnit): ScheduledFuture<*>
Link copied to clipboard
open override fun scheduleWithFixedDelay(p0: Runnable, p1: Long, p2: Long, p3: TimeUnit): ScheduledFuture<*>
Link copied to clipboard
open override fun shutdown()
Link copied to clipboard
open override fun shutdownGracefully(): Future<*>
open override fun shutdownGracefully(p0: Long, p1: Long, p2: TimeUnit): Future<*>
Link copied to clipboard
open override fun shutdownNow(): MutableList<Runnable>
Link copied to clipboard
open fun spliterator(): Spliterator<EventExecutor>
Link copied to clipboard
open override fun submit(p0: Runnable): Future<*>
open override fun <T : Any> submit(p0: Callable<T>): Future<T>
open override fun <T : Any> submit(p0: Runnable, p1: T): Future<T>
Link copied to clipboard
open override fun terminationFuture(): Future<*>