public void run()

in benchmark-java/src/main/java/org/apache/pekko/grpc/benchmarks/driver/LoadClient.java [263:283]

• 21 lines of code
• 5 McCabe index (conditional complexity)

    public void run() {
      while (true) {
        maxOutstanding.acquireUninterruptibly();
        if (shutdown) {
          maxOutstanding.release();
          return;
        }
        final long requestTime = System.nanoTime();
        CompletionStage<Messages.SimpleResponse> response = client.unaryCall(simpleRequest);
        response.whenComplete((rsp, t) -> {
          if (t == null) {
            delay(System.nanoTime() - requestTime);
            maxOutstanding.release();
          } else {
            maxOutstanding.release();
            Level level = shutdown ? Level.FINE : Level.INFO;
            log.log(level, "Error in AsyncUnary call", t);
          }
        });
      }
    }