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 64d1a36 commit 2a4c30aCopy full SHA for 2a4c30a
src/dataqueue/queue.cc
@@ -434,7 +434,13 @@ class NonIdempotentDataQueueReader final
434
CHECK(!data_queue_->is_idempotent());
435
}
436
437
- ~NonIdempotentDataQueueReader() { data_queue_->reader_destructed(this); }
+ ~NonIdempotentDataQueueReader() {
438
+ if (waited_next_) {
439
+ std::move(waited_next_)(
440
+ bob::Status::STATUS_EOS, nullptr, 0, [](uint64_t) {});
441
+ }
442
+ data_queue_->reader_destructed(this);
443
444
445
// Disallow moving and copying.
446
NonIdempotentDataQueueReader(const NonIdempotentDataQueueReader&) = delete;
0 commit comments