@Throws(InterruptedException::class)
  fun tearDown() {
    clientListener.assertExhausted()
  }

  @Test
  fun textMessage() {
    webServer.enqueue(
      MockResponse.Builder()
        .webSocketUpgrade(serverListener)
        .build(),
    )
    val webSocket: WebSocket = newWebSocket()
    clientListener.assertOpen()
    val server = serverListener.assertOpen()
    webSocket.send("Hello, WebSockets!")