Merge pull request #11 from TimelyDataflow/master

Seal: Drop chain while feeding data to builder (TimelyDataflow#482)
MaterializeInc · May 7, 2024 · 8d077e5 · 8d077e5
2 parents a3f0f31 + abe18c5
commit 8d077e5
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/src/trace/implementations/merge_batcher_col.rs b/src/trace/implementations/merge_batcher_col.rs
@@ -291,8 +291,10 @@ where
         }
         let mut builder = B::with_capacity(keys, vals, upds);
 
-        for datum in chain.iter().flat_map(|ts| ts.iter()) {
-            builder.copy(datum);
+        for chunk in chain.drain(..) {
+            for datum in chunk.iter() {
+                builder.copy(datum);
+            }
         }
 
         builder.done(lower.to_owned(), upper.to_owned(), since.to_owned())