Call callback immediately when token was already completed.

eclipse · Jul 4, 2024 · 9e378f5 · 9e378f5
1 parent 28477ca
commit 9e378f5
Showing 1 changed file with 16 additions and 0 deletions.
diff --git a/src/token.cpp b/src/token.cpp
@@ -257,6 +257,22 @@ void token::reset()
     errMsg_.clear();
 }
 
+void set_action_callback(iaction_listener& listener)
+{
+	guard g(lock_);
+	listener_ = &listener;
+
+	if (complete_)
+	{
+		g.unlock();
+
+		if (rc_ == MQTTASYNC_SUCCESS)
+			listener.on_success(*this);
+		else
+			listener.on_failure(*this);
+	}
+}
+
 void token::wait()
 {
     unique_lock g(lock_);