fix coroutines DelicateCoroutinesApi usage

rsocket · Nov 13, 2023 · 37430b0 · 37430b0
1 parent 67573af
commit 37430b0
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/rsocket-core/src/commonMain/kotlin/io/rsocket/kotlin/internal/RequestFlow.kt b/rsocket-core/src/commonMain/kotlin/io/rsocket/kotlin/internal/RequestFlow.kt
@@ -44,7 +44,7 @@ internal suspend inline fun FlowCollector<Payload>.emitAllWithRequestN(
 ) {
     val collector = object : RequestFlowCollector(this, strategy) {
         override suspend fun onRequest(n: Int) {
-            @OptIn(ExperimentalCoroutinesApi::class)
+            @OptIn(DelicateCoroutinesApi::class)
             if (!channel.isClosedForReceive) onRequest(n)
         }
     }

diff --git a/...mmonMain/kotlin/io/rsocket/kotlin/internal/handler/RequesterRequestChannelFrameHandler.kt b/...mmonMain/kotlin/io/rsocket/kotlin/internal/handler/RequesterRequestChannelFrameHandler.kt
@@ -70,7 +70,7 @@ internal class RequesterRequestChannelFrameHandler(
         return isCancelled
     }
 
-    @OptIn(ExperimentalCoroutinesApi::class)
+    @OptIn(DelicateCoroutinesApi::class)
     override fun onSendComplete() {
         if (channel.isClosedForSend) streamsStorage.remove(id)
     }

diff --git a/...mmonMain/kotlin/io/rsocket/kotlin/internal/handler/ResponderRequestChannelFrameHandler.kt b/...mmonMain/kotlin/io/rsocket/kotlin/internal/handler/ResponderRequestChannelFrameHandler.kt
@@ -67,7 +67,7 @@ internal class ResponderRequestChannelFrameHandler(
     }
 
     override fun onSendComplete() {
-        @OptIn(ExperimentalCoroutinesApi::class)
+        @OptIn(DelicateCoroutinesApi::class)
         if (channel.isClosedForSend) streamsStorage.remove(id)
     }