Fixed in_strand().

redboltz · Jan 8, 2024 · 558999d · 558999d
1 parent 808b2f2
commit 558999d
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/include/async_mqtt/broker/endpoint_variant.hpp b/include/async_mqtt/broker/endpoint_variant.hpp
@@ -113,10 +113,10 @@ class epsp_wrap {
         );
     }
 
-    bool running_in_this_thread() const {
+    bool in_strand() const {
         return visit(
             [&](auto& ep) -> bool {
-                return ep.strand().running_in_this_thread();
+                return ep.in_strand();
             }
         );
     }

diff --git a/include/async_mqtt/broker/offline_message.hpp b/include/async_mqtt/broker/offline_message.hpp
@@ -66,7 +66,7 @@ class offline_message {
 
     template <typename Epsp>
     bool send(Epsp epsp, protocol_version ver) {
-        BOOST_ASSERT(epsp.running_in_this_thread());
+        BOOST_ASSERT(epsp.in_strand());
         auto publish =
             [&] (packet_id_t pid) {
                 switch (ver) {