From 37430b053dcaee9110650436df8b15cb1462fd98 Mon Sep 17 00:00:00 2001
From: Oleg Yukhnevich <whyoleg@gmail.com>
Date: Mon, 13 Nov 2023 20:06:34 +0200
Subject: [PATCH] fix coroutines DelicateCoroutinesApi usage

---
 .../commonMain/kotlin/io/rsocket/kotlin/internal/RequestFlow.kt | 2 +-
 .../internal/handler/RequesterRequestChannelFrameHandler.kt     | 2 +-
 .../internal/handler/ResponderRequestChannelFrameHandler.kt     | 2 +-
 3 files changed, 3 insertions(+), 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
index 8694293a..244192dd 100644
--- 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/rsocket-core/src/commonMain/kotlin/io/rsocket/kotlin/internal/handler/RequesterRequestChannelFrameHandler.kt b/rsocket-core/src/commonMain/kotlin/io/rsocket/kotlin/internal/handler/RequesterRequestChannelFrameHandler.kt
index ad5f007a..43f0592d 100644
--- a/rsocket-core/src/commonMain/kotlin/io/rsocket/kotlin/internal/handler/RequesterRequestChannelFrameHandler.kt
+++ b/rsocket-core/src/commonMain/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/rsocket-core/src/commonMain/kotlin/io/rsocket/kotlin/internal/handler/ResponderRequestChannelFrameHandler.kt b/rsocket-core/src/commonMain/kotlin/io/rsocket/kotlin/internal/handler/ResponderRequestChannelFrameHandler.kt
index 45be9a63..888ad786 100644
--- a/rsocket-core/src/commonMain/kotlin/io/rsocket/kotlin/internal/handler/ResponderRequestChannelFrameHandler.kt
+++ b/rsocket-core/src/commonMain/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)
     }