| 629 | } |
| 630 | |
| 631 | void SpillMerger::finishSource(size_t streamIdx) const { |
| 632 | ContinueFuture future{ContinueFuture::makeEmpty()}; |
| 633 | sources_[streamIdx]->enqueue(nullptr, &future); |
| 634 | BOLT_CHECK(!future.valid()); |
| 635 | } |
| 636 | |
| 637 | void SpillMerger::readFromSpillFileStream( |
| 638 | const std::weak_ptr<SpillMerger>& mergeHolder, |