Package-level declarations

Types

Link copied to clipboard
object EngineMain

Netty engine

Link copied to clipboard
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.

Link copied to clipboard
abstract class NettyApplicationCall(application: Application, val context: ChannelHandlerContext, requestMessage: Any) : BaseApplicationCall
Link copied to clipboard
class NettyApplicationEngine(environment: ApplicationEnvironment, monitor: Events, developmentMode: Boolean, val configuration: NettyApplicationEngine.Configuration, applicationProvider: () -> Application) : BaseApplicationEngine

ApplicationEngine implementation for running in a standalone Netty

Link copied to clipboard
abstract class NettyApplicationRequest(call: PipelineCall, val coroutineContext: CoroutineContext, val context: ChannelHandlerContext, requestBodyChannel: ByteReadChannel, uri: String, keepAlive: Boolean) : BaseApplicationRequest, CoroutineScope
Link copied to clipboard
class NettyApplicationRequestHeaders(request: HttpRequest) : Headers
Link copied to clipboard
abstract class NettyApplicationResponse(call: NettyApplicationCall, context: ChannelHandlerContext, engineContext: CoroutineContext, userContext: CoroutineContext) : BaseApplicationResponse
Link copied to clipboard
class NettyChannelInitializer(applicationProvider: () -> Application, enginePipeline: EnginePipeline, environment: ApplicationEnvironment, callEventGroup: EventExecutorGroup, engineContext: CoroutineContext, userContext: CoroutineContext, connector: EngineConnectorConfig, runningLimit: Int, responseWriteTimeout: Int, requestReadTimeout: Int, httpServerCodec: () -> HttpServerCodec, channelPipelineConfig: ChannelPipeline.() -> Unit, enableHttp2: Boolean) : ChannelInitializer<SocketChannel>

A ChannelInitializer implementation that sets up the default ktor channel pipeline

Functions

Link copied to clipboard
suspend fun <T> Future<T>.suspendAwait(): T

Suspend until the future completion. Resumes with the same exception if the future completes exceptionally

suspend fun <T> Future<T>.suspendAwait(exception: (Throwable, Continuation<T>) -> Unit): T

Suspend until the future completion handling exception from the future using exception function

Link copied to clipboard
suspend fun <T> Future<T>.suspendWriteAwait(): T

Suspend until the future completion. Wraps futures completion exceptions into ChannelWriteException