summaryrefslogtreecommitdiff
path: root/implementation/service_discovery/src/remote_subscription_ack.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'implementation/service_discovery/src/remote_subscription_ack.cpp')
-rw-r--r--implementation/service_discovery/src/remote_subscription_ack.cpp5
1 files changed, 2 insertions, 3 deletions
diff --git a/implementation/service_discovery/src/remote_subscription_ack.cpp b/implementation/service_discovery/src/remote_subscription_ack.cpp
index 80be082..03270c9 100644
--- a/implementation/service_discovery/src/remote_subscription_ack.cpp
+++ b/implementation/service_discovery/src/remote_subscription_ack.cpp
@@ -59,15 +59,14 @@ remote_subscription_ack::get_target_address() const {
bool
remote_subscription_ack::is_pending() const {
for (const auto& its_subscription : subscriptions_) {
- if (its_subscription->is_pending()) {
+ if (its_subscription->is_pending()
+ && its_subscription->get_answers() != 0) {
return true;
}
}
return false;
}
-
-
std::set<std::shared_ptr<remote_subscription> >
remote_subscription_ack::get_subscriptions() const {
return subscriptions_;