4.0.1

http_client/com.hexagontk.http.client/HttpClient

HttpClient

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

Client to use other REST services.

Constructors

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

Properties

var cookies: List<Cookie>

val handler: HttpHandler? = null

val settings: HttpClientSettings

Functions

open override fun close()

fun cookiesMap(): Map<String, Cookie>

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

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

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

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

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

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

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

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

fun send(request: HttpRequest): HttpResponsePort

Synchronous execution.

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

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

fun start()

fun started(): Boolean

fun stop()

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