public synchronized ApiFuture notifyDataAvailable()

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

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

  public synchronized ApiFuture<Void> notifyDataAvailable() {
    if (permanentError.isPresent()) {
      return ApiFutures.immediateFailedFuture(permanentError.get());
    }
    if (!messages.isEmpty()) {
      return ApiFutures.immediateFuture(null);
    }
    if (!notification.isPresent()) {
      notification = Optional.of(SettableApiFuture.create());
    }
    return notification.get();
  }