http_client/com.hexagonkt.http.client/HttpClient

HttpClient

class HttpClient(adapter: HttpClientPort, val settings: HttpClientSettings = HttpClientSettings()) : Closeable

Client to use other REST services.

TODO Add support for client filters. I.e.: for auth, signing, etc.

Constructors

HttpClient

constructor(adapter: HttpClientPort, baseUrl: URL, settings: HttpClientSettings = HttpClientSettings())

constructor(adapter: HttpClientPort, baseUrl: String, settings: HttpClientSettings = HttpClientSettings())

constructor(adapter: HttpClientPort, settings: HttpClientSettings = HttpClientSettings())

Functions

open override fun close()

cookiesMap

fun cookiesMap(): Map<String, Cookie>

delete

fun delete(path: String = "", body: Any? = null, contentType: ContentType? = settings.contentType): HttpClientResponse

get

fun get(path: String = "", headers: Headers = Headers(), body: Any? = null, contentType: ContentType? = settings.contentType): HttpClientResponse

head

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

options

fun options(path: String = "", body: Any? = null, headers: Headers = Headers(), contentType: ContentType? = settings.contentType): HttpClientResponse

patch

fun patch(path: String = "", body: Any? = null, contentType: ContentType? = settings.contentType): HttpClientResponse

post

fun post(path: String = "", body: Any? = null, contentType: ContentType? = settings.contentType): HttpClientResponse

put

fun put(path: String = "", body: Any? = null, contentType: ContentType? = settings.contentType): HttpClientResponse

send

fun send(request: HttpClientRequest): HttpClientResponse

Synchronous execution.

sse

fun sse(request: HttpClientRequest): 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): HttpClientResponse

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: WsCloseStatus, reason: String) -> Unit = { _, _ -> }): WsSession

Properties

var cookies: List<Cookie>

settings

val settings: HttpClientSettings