in flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/PubSubSource.java [180:182]
public boolean isEndOfStreamSignalled() { return endOfStreamSignalled; }