Public/nushell
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

clean up closed subscribers on send

Browse Source
This commit is contained in:
Andy Gayton 2024-06-19 21:47:15 -04:00
parent f0a849ad77
commit 1a7add9335
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/signals.rs
View File

@ -15,10 +15,8 @@ pub(crate) fn ctrlc_protection(
ctrlc::set_handler(move || { ctrlc::set_handler(move || {
ctrlc.store(true, Ordering::SeqCst); ctrlc.store(true, Ordering::SeqCst);
if let Ok(subscribers) = subscribers.lock() { if let Ok(mut subscribers) = subscribers.lock() {
for subscriber in subscribers.iter() { subscribers.retain(|sender| sender.send(()).is_ok());
let _ = subscriber.send(());
}
} }
}) })
.expect("Error setting Ctrl-C handler"); .expect("Error setting Ctrl-C handler");