statsCache.asMap().entrySet().stream().forEach(e -> {
            final StatsObject data = e.getValue();
            final Long begin = data.remove(BEGIN_KEY);
            if (begin != null) {
                printStats(e.getKey(), data, begin, false);
            }
        });

    }

    public void begin(final Object keyObj) {
        getCacheKey(keyObj).ifPresent(key -> {
            try {

  private var testCount = 0

  override fun executionSkipped(
    testIdentifier: TestIdentifier,
    reason: String,
  ) {
    printStatus("-")
  }

  private fun printStatus(s: String) {
    if (++testCount % 80 == 0) {
      printStatus("\n")
    }
    originalSystemErr?.print(s)
  }

  override fun executionFinished(
    testIdentifier: TestIdentifier,

	if err != nil {
		return "", fmt.Errorf("failed to execute command on Envoy: %v", err)
	}
	return string(result), nil
}

func printStatus(c *cobra.Command, kubeClient kube.CLIClient, statsType, podName, podNamespace string) error {
	var stats string
	var err error

	switch statsType {
	case "", "server":