Remove ChannelWrapper (#5145)

Author: BoD

libraries/apollo-runtime/src/appleMain/kotlin/com/apollographql/apollo3/network/ws/NSURLSessionWebSocketEngine.kt

@@ -2,10 +2,10 @@ package com.apollographql.apollo3.network.ws
 
 import com.apollographql.apollo3.api.http.HttpHeader
 import com.apollographql.apollo3.exception.ApolloNetworkException
-import com.apollographql.apollo3.internal.ChannelWrapper
 import com.apollographql.apollo3.network.toNSData
 import kotlinx.cinterop.convert
 import kotlinx.coroutines.CompletableDeferred
+import kotlinx.coroutines.ExperimentalCoroutinesApi
 import kotlinx.coroutines.channels.Channel
 import okio.ByteString
 import okio.toByteString
@@ -61,7 +61,7 @@ actual class DefaultWebSocketEngine(
       setHTTPMethod("GET")
     }
 
-    val messageChannel = ChannelWrapper(Channel<String>(Channel.UNLIMITED))
+    val messageChannel = Channel<String>(Channel.UNLIMITED)
     val isOpen = CompletableDeferred<Boolean>()
 
     val connectionListener = object : WebSocketConnectionListener {
@@ -95,10 +95,11 @@ actual class DefaultWebSocketEngine(
 
 private class WebSocketConnectionImpl(
     val webSocket: NSURLSessionWebSocketTask,
-    val messageChannel: ChannelWrapper<String>,
+    val messageChannel: Channel<String>,
 ) : WebSocketConnection {
   init {
-    messageChannel.setInvokeOnClose {
+    @OptIn(ExperimentalCoroutinesApi::class)
+    messageChannel.invokeOnClose {
       webSocket.cancelWithCloseCode(
           closeCode = CLOSE_NORMAL.convert(),
           reason = null
@@ -112,7 +113,8 @@ private class WebSocketConnectionImpl(
   }
 
   override fun send(data: ByteString) {
-    if (!messageChannel.isClosed) {
+    @OptIn(ExperimentalCoroutinesApi::class)
+    if (!messageChannel.isClosedForSend) {
       val message = NSURLSessionWebSocketMessage(data.toByteArray().toNSData())
       val completionHandler = { error: NSError? ->
         if (error != null) handleError(error)
@@ -122,7 +124,8 @@ private class WebSocketConnectionImpl(
   }
 
   override fun send(string: String) {
-    if (!messageChannel.isClosed) {
+    @OptIn(ExperimentalCoroutinesApi::class)
+    if (!messageChannel.isClosedForSend) {
       val message = NSURLSessionWebSocketMessage(string)
       val completionHandler = { error: NSError? ->
         if (error != null) handleError(error)

libraries/apollo-runtime/src/commonMain/kotlin/com/apollographql/apollo3/internal/ChannelWrapper.kt

@@ -1,7 +1,6 @@
 package com.apollographql.apollo3.network.ws
 
 import com.apollographql.apollo3.api.http.HttpHeader
-import com.apollographql.apollo3.internal.ChannelWrapper
 import io.ktor.http.Headers
 import io.ktor.http.URLBuilder
 import io.ktor.http.URLProtocol
@@ -34,7 +33,7 @@ actual class DefaultWebSocketEngine : WebSocketEngine {
       }
     }.build()
     val socket = createWebSocket(newUrl.toString(), Headers.build { headers.forEach { append(it.name, it.value) } }).awaitConnection()
-    val messageChannel = ChannelWrapper(Channel<String>(Channel.UNLIMITED))
+    val messageChannel = Channel<String>(Channel.UNLIMITED)
     socket.onmessage = { messageEvent: MessageEvent ->
       val data = messageEvent.data
       if (data != null) {

libraries/apollo-runtime/src/jsMain/kotlin/com/apollographql/apollo3/network/ws/JsWebSocketEngine.kt

@@ -2,9 +2,9 @@ package com.apollographql.apollo3.network.ws
 
 import com.apollographql.apollo3.api.http.HttpHeader
 import com.apollographql.apollo3.exception.ApolloWebSocketClosedException
-import com.apollographql.apollo3.internal.ChannelWrapper
 import com.apollographql.apollo3.network.toOkHttpHeaders
 import kotlinx.coroutines.CompletableDeferred
+import kotlinx.coroutines.ExperimentalCoroutinesApi
 import kotlinx.coroutines.channels.Channel
 import okhttp3.OkHttpClient
 import okhttp3.Request
@@ -25,7 +25,7 @@ actual class DefaultWebSocketEngine(
       url: String,
       headers: List<HttpHeader>,
   ): WebSocketConnection {
-    val messageChannel = ChannelWrapper(Channel<String>(Channel.UNLIMITED))
+    val messageChannel = Channel<String>(Channel.UNLIMITED)
     val webSocketOpenResult = CompletableDeferred<Unit>()
 
     //println("opening $url")
@@ -71,7 +71,8 @@ actual class DefaultWebSocketEngine(
 
     webSocketOpenResult.await()
 
-    messageChannel.setInvokeOnClose {
+    @OptIn(ExperimentalCoroutinesApi::class)
+    messageChannel.invokeOnClose {
       // I think this is not necessary. The caller must call [WebSocketConnection.close] in all cases.
       // This should either trigger onClose or onFailure which should close the messageChannel
       //