public void run()

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

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

    public void run(SourceContext<OUT> sourceContext) throws Exception {
        PubSubCollector collector = new PubSubCollector(sourceContext);
        while (isRunning) {
            try {
                processMessage(sourceContext, subscriber.pull(), collector);
            } catch (InterruptedException | CancellationException e) {
                isRunning = false;
            }
        }
    }