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 f54a658 commit c0e3bafCopy full SHA for c0e3baf
src/dataqueue/queue.cc
@@ -481,7 +481,7 @@ class NonIdempotentDataQueueReader final
481
// status.
482
if (!data_queue_->is_capped()) {
483
// Do we have to call next?
484
- if (!(options & bob::OPTIONS_SYNC)) {
+ if (!(options & bob::OPTIONS_SYNC) && false) {
485
assert(!waited_next_);
486
next(bob::Status::STATUS_WAIT, nullptr, 0, [](uint64_t) {});
487
waited_next_ = std::move(next);
0 commit comments