docs: public static void main(String[] args) {
      BenchmarkSettings settings = BenchmarkSettings.from(args).build();
  
      new BenchmarkServiceState(settings, new BenchmarkServiceImpl())
          .runForAsync(
              state -> {
                LatencyHelper latencyHelper = new LatencyHelper(state);
  
                BenchmarkMeter clientToServiceMeter = state.meter("meter.client-to-service");
                BenchmarkMeter serviceToClientMeter = state.meter("meter.service-to-client");
  
                ServiceCall serviceCall = state.call();
  
                return i -> {
                  clientToServiceMeter.mark();
                  return serviceCall
                      .requestOne(enrichRequest())
                      .map(RequestOneBenchmark::enrichResponse)
                      .doOnNext(
                          message -> {
                            serviceToClientMeter.mark();
                            Optional.ofNullable(message.data())
                                .ifPresent(ReferenceCountUtil::safestRelease);
                            latencyHelper.calculate(message);
                          })
                      .doOnError(ex -> LOGGER.warn("Exception occured: " + ex));
                };
              });
    }