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

Package dev.inmo.micro_utils.ktor.client

Functions

createStandardWebsocketFlow

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

inputProvider

expect suspend fun MPPFile.inputProvider(): <Error class: unknown 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: unknown class>.openSecureWebSocketFlow( url: String, noinline checkReconnection: suspend (Throwable?) -> Boolean = { true }, noinline requestBuilder: <Error class: unknown class>.() -> Unit = {}): Flow<T>

openWebSocketFlow

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

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

tempUpload

expect suspend fun <Error class: unknown 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: unknown 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: unknown 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: unknown class>.throwOnUnsuccess(unsuccessMessage: () -> String)