)
      return
    }

    try {
      writer.writePing(ByteString.EMPTY)
    } catch (e: IOException) {
      failWebSocket(e = e, isWriter = true)
    }
  }

  fun failWebSocket(
    e: Exception,
    response: Response? = null,
    isWriter: Boolean = false,
  ) {
    val streamsToCancel: Streams?
    val streamsToClose: Streams?
    val writerToClose: WebSocketWriter?