diff --git a/Modules/Channels/js/src/test/scala/EchoWSTest.scala b/Modules/Channels/js/src/test/scala/EchoWSTest.scala index f6b5e6c8d..9ed9a4e3a 100644 --- 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 index c43b1e36c..dbceab184 100644 --- 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 {