micro_utils.dokka/dev.inmo.micro_utils.ktor.client

Package dev.inmo.micro_utils.ktor.client

Types

UnifiedRequester

class UnifiedRequester(val client: <ERROR CLASS> = HttpClient(), val serialFormat: <ERROR CLASS> = standardKtorSerialFormat)

Functions

createStandardWebsocketFlow

inline fun <T : Any> <ERROR CLASS>.createStandardWebsocketFlow( url: String, noinline checkReconnection: suspend (Throwable?) -> Boolean = { true }, noinline requestBuilder: <ERROR CLASS>.() -> Unit = {}): Flow<T>

inline fun <T> <ERROR CLASS>.createStandardWebsocketFlow( url: String, crossinline checkReconnection: suspend (Throwable?) -> Boolean = { true }, noinline requestBuilder: <ERROR CLASS>.() -> Unit = {}, crossinline conversation: suspend (StandardKtorSerialInputData) -> T): Flow<T>

inline fun <T> <ERROR CLASS>.createStandardWebsocketFlow( url: String, deserializer: <ERROR CLASS><T>, crossinline checkReconnection: suspend (Throwable?) -> Boolean = { true }, serialFormat: <ERROR CLASS> = standardKtorSerialFormat, noinline requestBuilder: <ERROR CLASS>.() -> Unit = {}): <ERROR CLASS>

encodeUrlQueryValue

fun <T> <ERROR CLASS><T>.encodeUrlQueryValue(value: T, serialFormat: <ERROR CLASS> = standardKtorSerialFormat): <ERROR CLASS>

inputProvider

expect suspend fun MPPFile.inputProvider(): <ERROR CLASS>

openBaseWebSocketFlow

inline fun <T : Any> openBaseWebSocketFlow(noinline checkReconnection: suspend (Throwable?) -> Boolean = { true }, noinline webSocketSessionRequest: suspend SendChannel<T>.() -> Unit): Flow<T>

openSecureWebSocketFlow

inline fun <T : Any> <ERROR CLASS>.openSecureWebSocketFlow( url: String, noinline checkReconnection: suspend (Throwable?) -> Boolean = { true }, noinline requestBuilder: <ERROR CLASS>.() -> Unit = {}): Flow<T>

openWebSocketFlow

inline fun <T : Any> <ERROR CLASS>.openWebSocketFlow( url: String, noinline checkReconnection: suspend (Throwable?) -> Boolean = { true }, noinline requestBuilder: <ERROR CLASS>.() -> Unit = {}): Flow<T>

inline fun <T : Any> <ERROR CLASS>.openWebSocketFlow( url: String, useSecureConnection: Boolean, noinline checkReconnection: suspend (Throwable?) -> Boolean = { true }, noinline requestBuilder: <ERROR CLASS>.() -> Unit = {}): Flow<T>

tempUpload

expect suspend fun <ERROR CLASS>.tempUpload( fullTempUploadDraftPath: String, file: MPPFile, onUpload: (uploaded: Long, count: Long) -> Unit = { _, _ -> }): TemporalFileId

suspend fun UnifiedRequester.tempUpload( fullTempUploadDraftPath: String, file: MPPFile, onUpload: (uploaded: Long, count: Long) -> Unit = { _, _ -> }): TemporalFileId

expect suspend fun <ERROR CLASS>.tempUpload( fullTempUploadDraftPath: String, file: MPPFile, onUpload: (uploaded: Long, count: Long) -> Unit = { _, _ -> }): TemporalFileId

suspend fun UnifiedRequester.tempUpload( fullTempUploadDraftPath: String, file: MPPFile, onUpload: (uploaded: Long, count: Long) -> Unit = { _, _ -> }): TemporalFileId

expect suspend fun <ERROR CLASS>.tempUpload( fullTempUploadDraftPath: String, file: MPPFile, onUpload: (uploaded: Long, count: Long) -> Unit = { _, _ -> }): TemporalFileId

suspend fun UnifiedRequester.tempUpload( fullTempUploadDraftPath: String, file: MPPFile, onUpload: (uploaded: Long, count: Long) -> Unit = { _, _ -> }): TemporalFileId

throwOnUnsuccess

inline fun <ERROR CLASS>.throwOnUnsuccess(unsuccessMessage: () -> String)

uniget

suspend fun <ResultType> <ERROR CLASS>.uniget( url: String, resultDeserializer: <ERROR CLASS><ResultType>, serialFormat: <ERROR CLASS> = standardKtorSerialFormat): <ERROR CLASS>

unimultipart

suspend fun <ResultType> <ERROR CLASS>.unimultipart( url: String, mppFile: MPPFile, resultDeserializer: <ERROR CLASS><ResultType>, mimetype: String = "*/*", additionalParametersBuilder: <ERROR CLASS>.() -> Unit = {}, dataHeadersBuilder: <ERROR CLASS>.() -> Unit = {}, requestBuilder: <ERROR CLASS>.() -> Unit = {}, serialFormat: <ERROR CLASS> = standardKtorSerialFormat): ResultType

suspend fun <BodyType, ResultType> <ERROR CLASS>.unimultipart( url: String, mppFile: MPPFile, otherData: Pair<<ERROR CLASS><BodyType>, BodyType>, resultDeserializer: <ERROR CLASS><ResultType>, mimetype: String = "*/*", additionalParametersBuilder: <ERROR CLASS>.() -> Unit = {}, dataHeadersBuilder: <ERROR CLASS>.() -> Unit = {}, requestBuilder: <ERROR CLASS>.() -> Unit = {}, serialFormat: <ERROR CLASS> = standardKtorSerialFormat): ResultType

suspend fun <ResultType> <ERROR CLASS>.unimultipart( url: String, filename: String, inputProvider: <ERROR CLASS>, resultDeserializer: <ERROR CLASS><ResultType>, mimetype: String = "*/*", additionalParametersBuilder: <ERROR CLASS>.() -> Unit = {}, dataHeadersBuilder: <ERROR CLASS>.() -> Unit = {}, requestBuilder: <ERROR CLASS>.() -> Unit = {}, serialFormat: <ERROR CLASS> = standardKtorSerialFormat): ResultType

suspend fun <BodyType, ResultType> <ERROR CLASS>.unimultipart( url: String, filename: String, otherData: Pair<<ERROR CLASS><BodyType>, BodyType>, inputProvider: <ERROR CLASS>, resultDeserializer: <ERROR CLASS><ResultType>, mimetype: String = "*/*", additionalParametersBuilder: <ERROR CLASS>.() -> Unit = {}, dataHeadersBuilder: <ERROR CLASS>.() -> Unit = {}, requestBuilder: <ERROR CLASS>.() -> Unit = {}, serialFormat: <ERROR CLASS> = standardKtorSerialFormat): ResultType

unipost

suspend fun <BodyType, ResultType> <ERROR CLASS>.unipost( url: String, bodyInfo: Pair<<ERROR CLASS><BodyType>, BodyType>, resultDeserializer: <ERROR CLASS><ResultType>, serialFormat: <ERROR CLASS> = standardKtorSerialFormat): <ERROR CLASS>

Properties

defaultRequester

val defaultRequester: UnifiedRequester