From 3a1371a5286bf2a060d50c8812154007f1de7641 Mon Sep 17 00:00:00 2001
From: VGalaxies <vgalaxies@apache.org>
Date: Fri, 14 Jun 2024 11:18:39 +0800
Subject: [PATCH] rename hasNoTopicsSubscribed -> hasMoreData

---
 .../org/apache/iotdb/SubscriptionSessionExample.java   |  4 ++--
 .../subscription/consumer/SubscriptionConsumer.java    | 10 +++++-----
 2 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/example/session/src/main/java/org/apache/iotdb/SubscriptionSessionExample.java b/example/session/src/main/java/org/apache/iotdb/SubscriptionSessionExample.java
index c9bd8af83eff..b205ae620878 100644
--- a/example/session/src/main/java/org/apache/iotdb/SubscriptionSessionExample.java
+++ b/example/session/src/main/java/org/apache/iotdb/SubscriptionSessionExample.java
@@ -265,7 +265,7 @@ private static void dataSubscription3() throws Exception {
                         .buildPushConsumer()) {
                   consumer3.open();
                   consumer3.subscribe(TOPIC_3);
-                  while (!consumer3.hasNoTopicsSubscribed()) {
+                  while (!consumer3.hasMoreData()) {
                     LockSupport.parkNanos(SLEEP_NS); // wait some time
                   }
                 }
@@ -307,7 +307,7 @@ private static void dataSubscription4() throws Exception {
                   consumer4.subscribe(TOPIC_4);
                   while (true) {
                     LockSupport.parkNanos(SLEEP_NS); // wait some time
-                    if (consumer4.hasNoTopicsSubscribed()) {
+                    if (consumer4.hasMoreData()) {
                       break;
                     }
                     for (final SubscriptionMessage message : consumer4.poll(POLL_TIMEOUT_MS)) {
diff --git a/iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/SubscriptionConsumer.java b/iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/SubscriptionConsumer.java
index 5ce3a430bc09..5b20ecf7c953 100644
--- a/iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/SubscriptionConsumer.java
+++ b/iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/SubscriptionConsumer.java
@@ -108,11 +108,11 @@ public String getConsumerGroupId() {
     return consumerGroupId;
   }
 
-  public Set<String> getSubscribedTopicNames() {
-    return subscribedTopicNames;
-  }
-
-  public boolean hasNoTopicsSubscribed() {
+  /**
+   * @return When <b>only</b> subscribing to the query mode topics, if there is no new data to
+   *     process, return {@code false}; otherwise, return {@code true}.
+   */
+  public boolean hasMoreData() {
     return subscribedTopicNames.isEmpty();
   }