ktor-client-cio

alltypes

object CIO : HttpClientEngineFactory<CIOEngineConfig>

fun create(block: CIOEngineConfig.() -> Unit): HttpClientEngine
fun toString(): String

class CIOEngineConfig : HttpClientEngineConfig

CIOEngineConfig()
val endpoint: EndpointConfig
val https: TLSConfigBuilder
fun https(block: TLSConfigBuilder.() -> Unit): TLSConfigBuilder
var maxConnectionsCount: Int
var requestTimeout: Long

class CIOEngineContainer : HttpClientEngineContainer

CIOEngineContainer()
val factory: HttpClientEngineFactory<*>
fun toString(): String

class ClientClosedException : IllegalStateException

ClientClosedException(cause: Throwable? = null)

open class ConnectException : Exception

ConnectException()

class EndpointConfig

EndpointConfig()
var allowHalfClose: Boolean
var connectAttempts: Int
var connectRetryAttempts: Int
var connectTimeout: Long
var keepAliveTime: Long
var maxConnectionsPerRoute: Int
var pipelineMaxSize: Int
var socketTimeout: Long

class FailToConnectException : Exception

FailToConnectException()

io.ktor.client.HttpClient

suspend fun HttpClient.webSocketRaw(method: HttpMethod = HttpMethod.Get, host: String = "localhost", port: Int = DEFAULT_PORT, path: String = "/", request: HttpRequestBuilder.() -> Unit = {}, block: suspend ClientWebSocketSession.() -> Unit): Unit
suspend fun HttpClient.webSocketRawSession(method: HttpMethod = HttpMethod.Get, host: String = "localhost", port: Int = DEFAULT_PORT, path: String = "/", block: HttpRequestBuilder.() -> Unit = {}): ClientWebSocketSession
suspend fun HttpClient.ws(urlString: String, request: HttpRequestBuilder.() -> Unit = {}, block: suspend DefaultClientWebSocketSession.() -> Unit): Unit
suspend fun HttpClient.wsRaw(method: HttpMethod = HttpMethod.Get, host: String = "localhost", port: Int = DEFAULT_PORT, path: String = "/", request: HttpRequestBuilder.() -> Unit = {}, block: suspend ClientWebSocketSession.() -> Unit): Unit
suspend fun HttpClient.wssRaw(method: HttpMethod = HttpMethod.Get, host: String = "localhost", port: Int = DEFAULT_PORT, path: String = "/", request: HttpRequestBuilder.() -> Unit = {}, block: suspend ClientWebSocketSession.() -> Unit): Unit

package io.ktor.client.engine.cio

object CIO : HttpClientEngineFactory<CIOEngineConfig>

fun create(block: CIOEngineConfig.() -> Unit): HttpClientEngine
fun toString(): String

class CIOEngineConfig : HttpClientEngineConfig

CIOEngineConfig()
val endpoint: EndpointConfig
val https: TLSConfigBuilder
fun https(block: TLSConfigBuilder.() -> Unit): TLSConfigBuilder
var maxConnectionsCount: Int
var requestTimeout: Long

class CIOEngineContainer : HttpClientEngineContainer

CIOEngineContainer()
val factory: HttpClientEngineFactory<*>
fun toString(): String

class ClientClosedException : IllegalStateException

ClientClosedException(cause: Throwable? = null)

open class ConnectException : Exception

ConnectException()

class EndpointConfig

EndpointConfig()
var allowHalfClose: Boolean
var connectAttempts: Int
var connectRetryAttempts: Int
var connectTimeout: Long
var keepAliveTime: Long
var maxConnectionsPerRoute: Int
var pipelineMaxSize: Int
var socketTimeout: Long

class FailToConnectException : Exception

FailToConnectException()

fun CIOEngineConfig.endpoint(block: EndpointConfig.() -> Unit): EndpointConfig

package io.ktor.client.features.websocket

io.ktor.client.HttpClient

suspend fun HttpClient.webSocketRaw(method: HttpMethod = HttpMethod.Get, host: String = "localhost", port: Int = DEFAULT_PORT, path: String = "/", request: HttpRequestBuilder.() -> Unit = {}, block: suspend ClientWebSocketSession.() -> Unit): Unit
suspend fun HttpClient.webSocketRawSession(method: HttpMethod = HttpMethod.Get, host: String = "localhost", port: Int = DEFAULT_PORT, path: String = "/", block: HttpRequestBuilder.() -> Unit = {}): ClientWebSocketSession
suspend fun HttpClient.ws(urlString: String, request: HttpRequestBuilder.() -> Unit = {}, block: suspend DefaultClientWebSocketSession.() -> Unit): Unit
suspend fun HttpClient.wsRaw(method: HttpMethod = HttpMethod.Get, host: String = "localhost", port: Int = DEFAULT_PORT, path: String = "/", request: HttpRequestBuilder.() -> Unit = {}, block: suspend ClientWebSocketSession.() -> Unit): Unit
suspend fun HttpClient.wssRaw(method: HttpMethod = HttpMethod.Get, host: String = "localhost", port: Int = DEFAULT_PORT, path: String = "/", request: HttpRequestBuilder.() -> Unit = {}, block: suspend ClientWebSocketSession.() -> Unit): Unit