private void createAndSetPubSubSubscriber()

in flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/PubSubSource.java [226:233]

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

    private void createAndSetPubSubSubscriber() throws Exception {
        if (subscriber == null) {
            this.subscriber = pubSubSubscriberFactory.getSubscriber(credentials);
        }
        if (acknowledgeOnCheckpoint == null) {
            this.acknowledgeOnCheckpoint = acknowledgeOnCheckpointFactory.create(subscriber);
        }
    }