finish plugin cellulite to the new indexer

This commit is contained in:
Tamo
2025-07-16 00:10:40 +02:00
parent 6be91c824c
commit 42d2af4c84
6 changed files with 43 additions and 27 deletions

View File

@ -75,8 +75,6 @@ pub fn merge_and_send_cellulite<'extractor, MSP>(
where
MSP: Fn() -> bool + Sync,
{
let cellulite = cellulite::Writer::new(index.cellulite);
for data in datastore {
if must_stop_processing() {
return Err(InternalError::AbortedIndexation.into());
@ -93,7 +91,8 @@ where
}
for result in frozen.iter_and_clear_inserted()? {
geojson_sender.send_geojson(result.map_err(InternalError::SerdeJson)?).unwrap();
let (docid, geojson) = result.map_err(InternalError::SerdeJson)?;
geojson_sender.send_geojson(docid, geojson).unwrap();
}
}