private static void ExecuteStreamingInputCalls()

in continuous_load_testing/src/main/java/com/google/net/grpc/testing/directpath/continuous_load_testing/Client.java [219:255]

35 lines of code
5 McCabe index (conditional complexity)


  private static void ExecuteStreamingInputCalls(TestServiceStub stub) {
    logger.info("ExecuteStreamingInputCalls");
    StreamingInputCallRequest request = StreamingInputCallRequest.newBuilder().build();
    final StreamObserver<StreamingInputCallResponse> responseObserver = new StreamObserver<>() {
      @Override
      public void onNext(StreamingInputCallResponse value) {
      }

      @Override
      public void onError(Throwable t) {
        StreamObserver<StreamingInputCallRequest> requestObserver = stub.streamingInputCall(
            this);
        for (int i = 0; i < num_of_requests; i++) {
          requestObserver.onNext(request);
        }
      }

      @Override
      public void onCompleted() {
        StreamObserver<StreamingInputCallRequest> requestObserver = stub.streamingInputCall(
            this);
        for (int i = 0; i < num_of_requests; i++) {
          requestObserver.onNext(request);
        }
      }
    };
    for (int i = 0; i < concurrency; i++) {
      Thread t = new Thread(() -> {
        StreamObserver<StreamingInputCallRequest> requestObserver = stub.streamingInputCall(
            responseObserver);
        for (int i1 = 0; i1 < num_of_requests; i1++) {
          requestObserver.onNext(request);
        }
      });
      t.start();
    }
  }