InsanusMokrassar/MicroUtils
1
0
Fork 0
mirror of https://github.com/InsanusMokrassar/MicroUtils.git synced 2024-11-22 16:23:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

fixes of deprecates

Browse Source
This commit is contained in:
InsanusMokrassar 2021-05-26 22:33:08 +06:00
parent 9566d6f81f
commit 2020e48659
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
coroutines/src/commonMain/kotlin/dev/inmo/micro_utils/coroutines/ActionsActor.kt
View File

@ -38,7 +38,7 @@ inline fun CoroutineScope.createSafeActionsActor(
suspend fun <T> Channel<suspend () -> Unit>.doWithSuspending( suspend fun <T> Channel<suspend () -> Unit>.doWithSuspending(
action: ActorAction<T> action: ActorAction<T>
) = suspendCoroutine<T> { ) = suspendCoroutine<T> {
offer { trySend {
safely({ e -> it.resumeWithException(e) }) { safely({ e -> it.resumeWithException(e) }) {
it.resume(action()) it.resume(action())
} }

2
ktor/server/src/jvmMain/kotlin/dev/inmo/micro_utils/ktor/server/FlowsWebsocket.kt
View File

@ -10,7 +10,7 @@ import kotlinx.coroutines.flow.collect
import kotlinx.serialization.SerializationStrategy import kotlinx.serialization.SerializationStrategy
private suspend fun DefaultWebSocketSession.checkReceivedAndCloseIfExists() { private suspend fun DefaultWebSocketSession.checkReceivedAndCloseIfExists() {
if (incoming.poll() != null) { if (incoming.tryReceive() != null) {
close() close()
throw CorrectCloseException throw CorrectCloseException
} }