scottk/wlan-cloud-lib-cppkafka
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-cloud-lib-cppkafka.git synced 2025-11-01 19:18:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

changed rbegin to begin

Browse Source
This commit is contained in:
accelerated
2018-12-14 16:32:33 -05:00
parent 4a24971d3f
commit 8b431c5421
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
include/cppkafka/utils/buffered_producer.h
View File

@@ -585,7 +585,7 @@ bool BufferedProducer<BufferType, Allocator>::flush(std::chrono::milliseconds ti
// Re-enqueue remaining messages in original order // Re-enqueue remaining messages in original order
if (!flush_queue.empty()) { if (!flush_queue.empty()) {
std::lock_guard<std::mutex> lock(mutex_); std::lock_guard<std::mutex> lock(mutex_);
messages_.insert(messages_.begin(), std::make_move_iterator(flush_queue.rbegin()), std::make_move_iterator(flush_queue.rend())) messages_.insert(messages_.begin(), std::make_move_iterator(flush_queue.begin()), std::make_move_iterator(flush_queue.end()));
} }
} }
else { else {