feedc0de/boost_mqtt5
1
0
Fork 0
forked from boostorg/mqtt5
Code Pull Requests Activity

Buildable with Boost 1.84

Browse Source 
Summary: related to T13686, #5

Reviewers: ivica

Reviewed By: ivica

Subscribers: miljen, iljazovic

Differential Revision: https://repo.mireo.local/D27869
This commit is contained in:
Korina Šimičević
2024-02-12 13:05:57 +01:00
parent d1d50d029d
commit eaac06fa6a
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
include/async_mqtt5/impl/async_sender.hpp
View File

@ -267,14 +267,14 @@ private:
_svc._replies.clear_fast_replies(); _svc._replies.clear_fast_replies();
auto ex = write_queue.front().get_executor();
auto alloc = write_queue.front().get_allocator(); auto alloc = write_queue.front().get_allocator();
auto ex = write_queue.front().get_executor();
_svc._stream.async_write( _svc._stream.async_write(
buffers, buffers,
asio::bind_executor( asio::bind_allocator(
ex, alloc,
asio::bind_allocator( asio::bind_executor(
alloc, ex,
asio::prepend(std::ref(*this), std::move(write_queue)) asio::prepend(std::ref(*this), std::move(write_queue))
) )
) )