private synchronized void completeNotification()

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

• 10 lines of code
• 3 McCabe index (conditional complexity)

  private synchronized void completeNotification(Optional<Throwable> t) {
    if (notification.isPresent()) {
      if (t.isPresent()) {
        notification.get().setException(t.get());
      } else {
        notification.get().set(null);
      }
      notification = Optional.absent();
    }
  }