Skip to content

Commit

Permalink
Merge branch 'master' into develop
Browse files Browse the repository at this point in the history
  • Loading branch information
fpagliughi committed Jul 14, 2023
2 parents 44d186e + 6bfe507 commit 20f09cc
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions src/mqtt/client.h
Original file line number Diff line number Diff line change
Expand Up @@ -68,17 +68,17 @@ class client : private callback
// Most are launched in a separate thread, for convenience, except
// message_arrived, for performance.
void connected(const string& cause) override {
std::async(std::launch::async, &callback::connected, userCallback_, cause);
std::async(std::launch::async, &callback::connected, userCallback_, cause).wait();
}
void connection_lost(const string& cause) override {
std::async(std::launch::async,
&callback::connection_lost, userCallback_, cause);
&callback::connection_lost, userCallback_, cause).wait();
}
void message_arrived(const_message_ptr msg) override {
userCallback_->message_arrived(msg);
}
void delivery_complete(delivery_token_ptr tok) override {
std::async(std::launch::async, &callback::delivery_complete, userCallback_, tok);
std::async(std::launch::async, &callback::delivery_complete, userCallback_, tok).wait();
}

/** Non-copyable */
Expand Down

0 comments on commit 20f09cc

Please sign in to comment.