fix(consumer): mark the tracker as closed when we've finished spawning threads so that the indexer can auto-exit on crash

Parakeet is a Rust-based Bluesky AppServer aiming to implement most of the functionality required to support the Bluesky client

appview atproto bluesky rust appserver

fork atom

mia.omg.lol 8 months ago bcc8fd21 d6d33e21

+2 -3

1 changed file

expand all

consumer

src

main.rs

+2 -3

consumer/src/main.rs

··· 132 tracker.spawn(index_transport(index_client, idxc_rx)); 133 } 134 135 - let tc = tracker.clone(); 136 - tracker.spawn(async move { 137 let _ = ctrl_c().await; 138 tracing::info!("stopping consumer"); 139 stop_tx.send(true).unwrap(); 140 - tc.close(); 141 }); 142 143 tracker.wait().await; 144 145 Ok(())

··· 132 tracker.spawn(index_transport(index_client, idxc_rx)); 133 } 134 135 + tokio::spawn(async move { 136 let _ = ctrl_c().await; 137 tracing::info!("stopping consumer"); 138 stop_tx.send(true).unwrap(); 139 }); 140 141 + tracker.close(); 142 tracker.wait().await; 143 144 Ok(())