From ff7f4629812cfd651c5d01694346b9adfb5b512e Mon Sep 17 00:00:00 2001 From: Pekka Enberg Date: Mon, 13 Oct 2025 10:57:30 +0300 Subject: [PATCH] core/vdbe/sorter: Replace IOCompletions::Many with completion group --- core/vdbe/sorter.rs | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/core/vdbe/sorter.rs b/core/vdbe/sorter.rs index 0e9eec00b..4f1f190f6 100644 --- a/core/vdbe/sorter.rs +++ b/core/vdbe/sorter.rs @@ -298,9 +298,11 @@ impl Sorter { fn next_from_chunk_heap(&mut self) -> Result>> { if !self.pending_completions.is_empty() { - return Ok(IOResult::IO(IOCompletions::Many( - self.pending_completions.drain(..).collect(), - ))); + let mut group = CompletionGroup::new(|_| {}); + for c in self.pending_completions.drain(..) { + group.add(&c); + } + return Ok(IOResult::IO(IOCompletions::Single(group.build()))); } // Make sure all chunks read at least one record into their buffer. if let Some((next_record, next_chunk_idx)) = self.chunk_heap.pop() {