public RecordsBySplits fetch()

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

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

  public RecordsBySplits<PubsubMessage> fetch() throws IOException {
    RecordsBySplits.Builder<PubsubMessage> builder = new RecordsBySplits.Builder<>();
    if (subscribers.isEmpty()) {
      return builder.build();
    }
    try {
      notifyDataAvailable().get();
      getMessages().asMap().forEach(builder::addAll);
    } catch (Throwable t) {
      throw new IOException(t);
    }
    return builder.build();
  }