We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a545ed6 commit d3349c0Copy full SHA for d3349c0
src/dataqueue/queue.cc
@@ -651,7 +651,7 @@ std::shared_ptr<DataQueue::Reader> DataQueueImpl::get_reader() {
651
auto reader =
652
std::make_shared<IdempotentDataQueueReader>(shared_from_this());
653
readers_.insert(reader.get());
654
- return std::move(reader);
+ return reader;
655
}
656
657
if (locked_to_reader_) return nullptr;
@@ -660,7 +660,7 @@ std::shared_ptr<DataQueue::Reader> DataQueueImpl::get_reader() {
660
661
std::make_shared<NonIdempotentDataQueueReader>(shared_from_this());
662
663
664
665
666
// ============================================================================
0 commit comments