microcosm.blue / repo-stream
Fast and robust atproto CAR file processing in rust
14
fork

Configure Feed

Select the types of activity you want to include in your feed.

only one chunk in the walker channel

conserve memory (unless something indicates that raising this would be useful)

phil 71b442f0 9437513f

+1 -1
+1 -1
src/drive.rs
··· 346 346 }) 347 347 .await??; 348 348 349 - let (tx, mut rx) = mpsc::channel::<Vec<(Cid, MaybeProcessedBlock<T>)>>(2); 349 + let (tx, mut rx) = mpsc::channel::<Vec<(Cid, MaybeProcessedBlock<T>)>>(1); 350 350 351 351 let store_worker = tokio::task::spawn_blocking(move || { 352 352 let mut writer = store.get_writer()?;