Package dev.inmo.micro_utils.ktor.client

Functions

createStandardWebsocketFlow
Link copied to clipboard
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>
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>
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
Link copied to clipboard
expect suspend fun MPPFile.inputProvider(): <Error class: unknown class>
expect suspend fun MPPFile.inputProvider(): <Error class: unknown class>
expect suspend fun MPPFile.inputProvider(): <Error class: unknown class>
openBaseWebSocketFlow
Link copied to clipboard
inline fun <T : Any> openBaseWebSocketFlow(noinline checkReconnection: suspend (Throwable?) -> Boolean = { true }, noinline webSocketSessionRequest: suspend SendChannel<T>.() -> Unit): Flow<T>
inline fun <T : Any> openBaseWebSocketFlow(noinline checkReconnection: suspend (Throwable?) -> Boolean = { true }, noinline webSocketSessionRequest: suspend SendChannel<T>.() -> Unit): Flow<T>
inline fun <T : Any> openBaseWebSocketFlow(noinline checkReconnection: suspend (Throwable?) -> Boolean = { true }, noinline webSocketSessionRequest: suspend SendChannel<T>.() -> Unit): Flow<T>
openSecureWebSocketFlow
Link copied to clipboard
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>
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>
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
Link copied to clipboard
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>
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>
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
Link copied to clipboard
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
Link copied to clipboard
inline fun <Error class: unknown class>.throwOnUnsuccess(unsuccessMessage: () -> String)
inline fun <Error class: unknown class>.throwOnUnsuccess(unsuccessMessage: () -> String)
inline fun <Error class: unknown class>.throwOnUnsuccess(unsuccessMessage: () -> String)