hopefully fix ktor update issues

build.gradle

@@ -38,7 +38,7 @@ buildscript {
 }
 
 group 'io.kweb'
-version '0.3.8'
+version '0.3.9'
 
 apply plugin: 'java'
 

src/main/kotlin/io/kweb/Kweb.kt

@@ -19,7 +19,6 @@ import io.kweb.browserConnection.KwebClientConnection.Caching
 import io.kweb.dev.hotswap.KwebHotswapPlugin
 import io.kweb.plugins.KWebPlugin
 import kotlinx.coroutines.*
-import kotlinx.coroutines.channels.consumeEach
 import kotlinx.coroutines.time.delay
 import org.apache.commons.io.IOUtils
 import java.io.*
@@ -207,8 +206,7 @@ class Kweb(val port: Int,
 
                 webSocket("/ws") {
 
-                    val hello = gson.fromJson<Client2ServerMessage>((incoming as Text).readText())
-
+                    val hello = gson.fromJson<Client2ServerMessage>(((incoming.receive() as Text).readText()))
 
                     if (hello.hello == null) {
                         throw RuntimeException("First message from client isn't 'hello'")
@@ -227,7 +225,7 @@ class Kweb(val port: Int,
 
 
                     try {
-                        incoming.consumeEach { frame ->
+                        for (frame in incoming) {
                             try {
                                 logger.debug { "Message received from client" }
 

src/main/kotlin/io/kweb/browserConnection/KwebClientConnection.kt

@@ -3,7 +3,7 @@ package io.kweb.browserConnection
 import io.ktor.http.cio.websocket.*
 import io.ktor.http.cio.websocket.Frame.Text
 import kotlinx.coroutines.*
-import kotlinx.coroutines.channels.*
+import kotlinx.coroutines.channels.Channel
 import mu.KotlinLogging
 import java.util.concurrent.ConcurrentLinkedQueue
 
@@ -12,7 +12,7 @@ private val logger = KotlinLogging.logger {}
 sealed class KwebClientConnection {
     abstract fun send(message: String)
 
-    @ObsoleteCoroutinesApi // TODO: For Channel.consumeEach, which will apparently become obsolete
+    //@ObsoleteCoroutinesApi // TODO: For Channel.consumeEach, which will apparently become obsolete
     class WebSocket(private val channel: WebSocketSession) : KwebClientConnection() {
 
         @Volatile var sendCount = 0
@@ -21,7 +21,9 @@ sealed class KwebClientConnection {
 
         init {
              GlobalScope.launch {
-                sendBuffer.consumeEach { channel.send(it) }
+                 for (frame in sendBuffer) {
+                     channel.send(frame)
+                 }
             }
 
         }