clientListener.assertExhausted()
    serverListener.assertClosing(1000, "")
    serverListener.assertClosed(1000, "")
    serverListener.assertExhausted()
  }

  @Test
  fun unplannedCloseHandledWithoutFailure() {
    webServer.enqueue(
      MockResponse.Builder()
        .webSocketUpgrade(serverListener)
        .build(),
    )
    newWebSocket()
    val webSocket = clientListener.assertOpen()