private void createPullSubscribers()

in ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober/Prober.java [632:656]

23 lines of code
4 McCabe index (conditional complexity)


  private void createPullSubscribers() {
    pullSubscribers = new GrpcSubscriberStub[subscriberCount];
    logger.log(Level.INFO, "Creating Pull Subscribers");

    for (int i = 0; i < subscriberCount; ++i) {
      final int index = i;
      pullSubscriberFutures[i] =
          executor.submit(
              () -> {
                SubscriberStubSettings.Builder subscriberStubSettings =
                    SubscriberStubSettings.newBuilder().setEndpoint(endpoint);
                try {
                  pullSubscribers[index] =
                      GrpcSubscriberStub.create(subscriberStubSettings.build());

                } catch (IOException e) {
                  logger.log(Level.SEVERE, "Could not create pull subscriber.", e);
                  return;
                }
                for (int j = 0; j < pullCount; ++j) {
                  doPullIteration(index);
                }
              });
    }
  }