narf

rescala-lang · Dec 13, 2024 · c14cc95 · c14cc95
1 parent e8be5af
commit c14cc95
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/Modules/Channels/js/src/test/scala/EchoWSTest.scala b/Modules/Channels/js/src/test/scala/EchoWSTest.scala
@@ -9,10 +9,13 @@ class EchoWSTest extends munit.FunSuite {
 
   test("echo") {
 
-    val outgoing = WebsocketConnect.connect("wss://echo.websocket.org/.ws").prepare: conn =>
-      TestUtil.printErrors { msg =>
-        println(s"received: ${new String(msg.asArray)}")
+    val outgoing = WebsocketConnect.connect("wss://echo.websocket.org/.ws").prepare { conn =>
+      {
+        case Success(msg) =>
+          println(s"received: ${new String(msg.asArray)}")
+        case Failure(ex) => ex.printStackTrace()
       }
+    }
 
     val fut = Async[Abort]:
       val wsc = outgoing.bind

diff --git a/Modules/Channels/shared/src/test/scala/channels/TestUtil.scala b/Modules/Channels/shared/src/test/scala/channels/TestUtil.scala
@@ -3,10 +3,7 @@ package channels
 import de.rmgk.delay.Callback
 
 import java.io.IOException
-import java.net.{InetAddress, InetSocketAddress, ServerSocket, SocketException}
 import java.nio.channels.ClosedChannelException
-import java.util.concurrent.{Executors, Semaphore}
-import scala.concurrent.ExecutionContext
 import scala.util.{Failure, Success}
 
 object TestUtil {