  @Test
  public void testCustomMetrics()
      throws InterruptedException, ExecutionException, TimeoutException {

    // #SemanticMetricRegistry
    final SemanticMetricRegistry registry = new SemanticMetricRegistry();
    final MetricId metricId = MetricId.build().tagged("service", "my-application");
    // #SemanticMetricRegistry

    final CustomMetricsExample example = new CustomMetricsExample(registry, metricId);

    example.predict(3, 1, -4, -42, 42, -10).toCompletableFuture().join();

    registry.getCounters().values().forEach(counter -> Assert.assertEquals(3, counter.getCount()));
  }