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 1a8378f commit c3146dbCopy full SHA for c3146db
src/dataqueue/queue.cc
@@ -434,13 +434,7 @@ class NonIdempotentDataQueueReader final
434
CHECK(!data_queue_->is_idempotent());
435
}
436
437
- ~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
+ ~NonIdempotentDataQueueReader() { data_queue_->reader_destructed(this); }
444
445
// Disallow moving and copying.
446
NonIdempotentDataQueueReader(const NonIdempotentDataQueueReader&) = delete;
0 commit comments