in flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/PubSubSource.java [124:133]
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;
}
}
}