private List pull()

in flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/BlockingGrpcPubSubSubscriber.java [70:82]

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

    private List<ReceivedMessage> pull(int retriesRemaining) {
        try {
            return stub.withDeadlineAfter(timeout.toMillis(), TimeUnit.MILLISECONDS)
                    .pull(pullRequest)
                    .getReceivedMessagesList();
        } catch (StatusRuntimeException e) {
            if (retriesRemaining > 0) {
                return pull(retriesRemaining - 1);
            }

            throw e;
        }
    }