public void close()

in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/PubSubSplitReader.java [116:128]

• 13 lines of code
• 4 McCabe index (conditional complexity)

  public void close() throws Exception {
    Exception exception = null;
    for (NotifyingPullSubscriber subscriber : subscribers.values()) {
      try {
        subscriber.shutdown();
      } catch (Exception e) {
        exception = e;
      }
    }
    if (exception != null) {
      throw exception;
    }
  }