ktor-server-netty/io.ktor.server.netty/EventLoopGroupProxy

EventLoopGroupProxy

class EventLoopGroupProxy(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

EventLoopGroupProxy

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

Types

Companion

object Companion

Functions

awaitTermination

open override fun awaitTermination(p0: Long, p1: TimeUnit): Boolean

execute

open override fun execute(p0: Runnable)

forEach

open fun forEach(p0: Consumer<in EventExecutor>)

invokeAll

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>>

invokeAny

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

isShutdown

open override fun isShutdown(): Boolean

isShuttingDown

open override fun isShuttingDown(): Boolean

isTerminated

open override fun isTerminated(): Boolean

iterator

open operator override fun iterator(): MutableIterator<EventExecutor>

open operator override fun next(): EventLoop

open override fun register(p0: Channel): ChannelFuture

open override fun register(p0: ChannelPromise): ChannelFuture

~~open~~ ~~override~~ ~~fun~~ ~~register~~(p0: Channel, p1: ChannelPromise): ChannelFuture

schedule

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>

scheduleAtFixedRate

open override fun scheduleAtFixedRate(p0: Runnable, p1: Long, p2: Long, p3: TimeUnit): ScheduledFuture<*>

scheduleWithFixedDelay

open override fun scheduleWithFixedDelay(p0: Runnable, p1: Long, p2: Long, p3: TimeUnit): ScheduledFuture<*>

shutdown

~~open~~ ~~override~~ ~~fun~~ ~~shutdown~~()

shutdownGracefully

open override fun shutdownGracefully(): Future<*>

open override fun shutdownGracefully(p0: Long, p1: Long, p2: TimeUnit): Future<*>

shutdownNow

~~open~~ ~~override~~ ~~fun~~ ~~shutdownNow~~(): MutableList<Runnable>

spliterator

open fun spliterator(): Spliterator<EventExecutor>

submit

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>

terminationFuture

open override fun terminationFuture(): Future<*>

Properties

channel

val channel: KClass<out ServerSocketChannel>