http_client/com.hexagonkt.http.client/HttpClient

HttpClient

class HttpClient(adapter: HttpClientPort, val settings: HttpClientSettings = HttpClientSettings(), val handler: HttpHandler? = null) : Closeable

Client to use other REST services.

Constructors

HttpClient

constructor(adapter: HttpClientPort, settings: HttpClientSettings = HttpClientSettings(), handler: HttpHandler? = null)

Properties

var cookies: List<Cookie>

handler

val handler: HttpHandler? = null

settings

val settings: HttpClientSettings

Functions

open override fun close()

cookiesMap

fun cookiesMap(): Map<String, Cookie>

delete

fun delete( path: String = "", body: Any? = null, contentType: ContentType? = settings.contentType, accept: List<ContentType> = settings.accept): HttpResponsePort

get

fun get( path: String = "", headers: Headers = Headers(), body: Any? = null, contentType: ContentType? = settings.contentType, accept: List<ContentType> = settings.accept): HttpResponsePort

head

fun head(path: String = "", headers: Headers = Headers()): HttpResponsePort

options

fun options( path: String = "", body: Any? = null, headers: Headers = Headers(), contentType: ContentType? = settings.contentType, accept: List<ContentType> = settings.accept): HttpResponsePort

patch

fun patch( path: String = "", body: Any? = null, contentType: ContentType? = settings.contentType, accept: List<ContentType> = settings.accept): HttpResponsePort

post

fun post( path: String = "", body: Any? = null, contentType: ContentType? = settings.contentType, accept: List<ContentType> = settings.accept): HttpResponsePort

put

fun put( path: String = "", body: Any? = null, contentType: ContentType? = settings.contentType, accept: List<ContentType> = settings.accept): HttpResponsePort

request

fun request(block: HttpClient.() -> Unit)

send

fun send(request: HttpRequest, attributes: Map<String, Any> = emptyMap()): HttpResponsePort

Synchronous execution.

sse

fun sse(request: HttpRequest): Flow.Publisher<ServerEvent>

fun sse(path: String): Flow.Publisher<ServerEvent>

start

fun start()

started

fun started(): Boolean

stop

fun stop()

trace

fun trace( path: String = "", body: Any? = null, contentType: ContentType? = settings.contentType, accept: List<ContentType> = settings.accept): HttpResponsePort

fun ws( path: String, onConnect: WsSession.() -> Unit = {}, onBinary: WsSession.(data: ByteArray) -> Unit = {}, onText: WsSession.(text: String) -> Unit = {}, onPing: WsSession.(data: ByteArray) -> Unit = {}, onPong: WsSession.(data: ByteArray) -> Unit = {}, onClose: WsSession.(status: Int, reason: String) -> Unit = { _, _ -> }): WsSession