ktor-http-cio
Module Contents
alltypes
Module Contents
class CIOHeaders : Headers
class CIOMultipartDataBase : MultiPartData, CoroutineScope
data class CloseReason
class ConnectionOptions
typealias DecoderJob = WriterJob
expect interface DefaultWebSocketSession : WebSocketSession
class DefaultWebSocketSessionImpl : DefaultWebSocketSession, WebSocketSession
typealias EncoderJob = ReaderJob
annotation class ExperimentalWebSocketExtensionApi
sealed expect class Frame
class FrameParser
enum class FrameType
class HttpHeadersMap
abstract class HttpMessage
typealias HttpRequestHandler = suspend ServerRequestScope.(request: Request) -> Unit
sealed class MultipartEvent
class MutableRange
class ParserException : Exception
class RawWebSocket : WebSocketSession
class Request : HttpMessage
expect class RequestResponseBuilder
class Response : HttpMessage
class Serializer
class ServerIncomingConnection
class ServerRequestScope : CoroutineScope
class SimpleFrameCollector
class WeakTimeoutQueue
class WebSocketDeflateExtension : WebSocketExtension<Config>
interface WebSocketExtension<ConfigType : Any>
interface WebSocketExtensionFactory<ConfigType : Any, ExtensionType : WebSocketExtension<ConfigType>>
class WebSocketExtensionHeader
class WebSocketExtensionsConfig
annotation class WebSocketInternalAPI
class WebSocketReader : CoroutineScope
expect interface WebSocketSession : CoroutineScope
class WebSocketWriter : CoroutineScope
kotlinx.coroutines.CoroutineScope
Module Contents
fun CoroutineScope.decodeChunked(input: ByteReadChannel): DecoderJob
fun CoroutineScope.decodeChunked(input: ByteReadChannel, contentLength: Long): DecoderJob
fun CoroutineScope.parseMultipart(: ByteReadChannel, : HttpHeadersMap): ReceiveChannel<MultipartEvent>
fun CoroutineScope.parseMultipart(input: ByteReadChannel, contentType: CharSequence, contentLength: Long?): ReceiveChannel<MultipartEvent>
fun CoroutineScope.parseMultipart(boundaryPrefixed: ByteBuffer, input: ByteReadChannel, totalLength: Long?): ReceiveChannel<MultipartEvent>
fun CoroutineScope.startConnectionPipeline(input: ByteReadChannel, output: ByteWriteChannel, timeout: WeakTimeoutQueue, handler: suspend CoroutineScope.(request: Request, input: ByteReadChannel, output: ByteWriteChannel, upgraded: CompletableDeferred<Boolean>?) -> Unit): Job
kotlinx.coroutines.CoroutineScope
kotlinx.coroutines.CoroutineScope
package io.ktor.http.cio
Module Contents
class CIOHeaders : Headers
class CIOMultipartDataBase : MultiPartData, CoroutineScope
class ConnectionOptions
typealias DecoderJob = WriterJob
typealias EncoderJob = ReaderJob
class HttpHeadersMap
abstract class HttpMessage
val HttpPipelineCoroutine: CoroutineName
val HttpPipelineWriterCoroutine: CoroutineName
typealias HttpRequestHandler = suspend ServerRequestScope.(request: Request) -> Unit
sealed class MultipartEvent
class ParserException : Exception
class Request : HttpMessage
val RequestHandlerCoroutine: CoroutineName
expect class RequestResponseBuilder
class Response : HttpMessage
suspend fun boundary(boundaryPrefixed: ByteBuffer, input: ByteReadChannel): Boolean
suspend fun copyMultipart(: HttpHeadersMap, : ByteReadChannel, : ByteWriteChannel): Unit
suspend fun decodeChunked(input: ByteReadChannel, out: ByteWriteChannel): Unit
suspend fun decodeChunked(input: ByteReadChannel, out: ByteWriteChannel, contentLength: Long): Unit
fun HttpHeadersMap.dumpTo(: String, : Appendable): Unit
suspend fun encodeChunked(output: ByteWriteChannel, coroutineContext: <ERROR CLASS>): EncoderJob
suspend fun encodeChunked(output: ByteWriteChannel, input: ByteReadChannel): Unit
fun expectHttpBody(method: HttpMethod, contentLength: Long, transferEncoding: CharSequence?, connectionOptions: ConnectionOptions?, contentType: CharSequence?): Boolean
fun expectHttpBody(request: Request): Boolean
fun expectHttpUpgrade(method: HttpMethod, upgrade: CharSequence?, connectionOptions: ConnectionOptions?): Boolean
fun expectHttpUpgrade(request: Request): Boolean
fun expectMultipart(: HttpHeadersMap): Boolean
kotlinx.coroutines.CoroutineScope
Module Contents
fun CoroutineScope.decodeChunked(input: ByteReadChannel): DecoderJob
fun CoroutineScope.decodeChunked(input: ByteReadChannel, contentLength: Long): DecoderJob
fun CoroutineScope.parseMultipart(: ByteReadChannel, : HttpHeadersMap): ReceiveChannel<MultipartEvent>
fun CoroutineScope.parseMultipart(input: ByteReadChannel, contentType: CharSequence, contentLength: Long?): ReceiveChannel<MultipartEvent>
fun CoroutineScope.parseMultipart(boundaryPrefixed: ByteBuffer, input: ByteReadChannel, totalLength: Long?): ReceiveChannel<MultipartEvent>
fun CoroutineScope.startConnectionPipeline(input: ByteReadChannel, output: ByteWriteChannel, timeout: WeakTimeoutQueue, handler: suspend CoroutineScope.(request: Request, input: ByteReadChannel, output: ByteWriteChannel, upgraded: CompletableDeferred<Boolean>?) -> Unit): Job
fun lastHttpRequest(http11: Boolean, connectionOptions: ConnectionOptions?): Boolean
fun parseBoundary(contentType: CharSequence): ByteBuffer
suspend fun parseHeaders(: ByteReadChannel): HttpHeadersMap
suspend fun parseHttpBody(contentLength: Long, transferEncoding: CharSequence?, connectionOptions: ConnectionOptions?, input: ByteReadChannel, out: ByteWriteChannel): Unit
suspend fun parseHttpBody(headers: HttpHeadersMap, input: ByteReadChannel, out: ByteWriteChannel): Unit
fun parseMultipart(: <ERROR CLASS>, : ByteReadChannel, : HttpHeadersMap): ReceiveChannel<MultipartEvent>
fun parseMultipart(coroutineContext: <ERROR CLASS>, input: ByteReadChannel, contentType: CharSequence, contentLength: Long?): ReceiveChannel<MultipartEvent>
fun parseMultipart(coroutineContext: <ERROR CLASS>, boundaryPrefixed: ByteBuffer, input: ByteReadChannel, totalLength: Long?): ReceiveChannel<MultipartEvent>
suspend fun parsePart(boundaryPrefixed: ByteBuffer, input: ByteReadChannel, output: ByteWriteChannel, limit: Long = Long.MAX_VALUE): Pair<HttpHeadersMap, Long>
suspend fun parsePartBody(boundaryPrefixed: ByteBuffer, input: ByteReadChannel, output: ByteWriteChannel, headers: HttpHeadersMap, limit: Long = Long.MAX_VALUE): Long
suspend fun parsePartHeaders(: ByteReadChannel): HttpHeadersMap
suspend fun parsePreamble(boundaryPrefixed: ByteBuffer, input: ByteReadChannel, output: BytePacketBuilder, limit: Long = Long.MAX_VALUE): Long
suspend fun parseRequest(input: ByteReadChannel): Request?
suspend fun parseResponse(input: ByteReadChannel): Response?
package io.ktor.http.cio.internals
package io.ktor.http.cio.websocket
package io.ktor.server.cio.backend