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 f5bcc41 commit 92fd1aaCopy full SHA for 92fd1aa
src/dataqueue/queue.cc
@@ -447,12 +447,14 @@ class NonIdempotentDataQueueReader final
447
void newDataOrEnd() override {
448
if (waited_next_) {
449
auto next = std::move(waited_next_);
450
- data_queue_->env()->SetImmediate(
+ /* data_queue_->env()->SetImmediate(
451
[next, dropme = shared_from_this()](Environment* env) {
452
std::move(next)(
453
bob::Status::STATUS_CONTINUE, nullptr, 0, [](uint64_t) {});
454
},
455
- CallbackFlags::kUnrefed);
+ CallbackFlags::kUnrefed); */
456
+ std::move(next)(
457
+ bob::Status::STATUS_CONTINUE, nullptr, 0, [](uint64_t) {});
458
}
459
460
0 commit comments