diff --git a/crates/milli/src/update/new/indexer/mod.rs b/crates/milli/src/update/new/indexer/mod.rs index d4c4841bc..e68a1ad4d 100644 --- a/crates/milli/src/update/new/indexer/mod.rs +++ b/crates/milli/src/update/new/indexer/mod.rs @@ -110,7 +110,7 @@ where }, ); - let (extractor_sender, mut writer_receiver) = pool + let (extractor_sender, writer_receiver) = pool .install(|| extractor_writer_bbqueue(&mut bbbuffers, total_bbbuffer_capacity, 1000)) .unwrap(); @@ -425,6 +425,7 @@ where let mut arroy_writers = arroy_writers?; { + let mut writer_receiver = writer_receiver; let span = tracing::trace_span!(target: "indexing::write_db", "all"); let _entered = span.enter();