From bf677e1f9ce07e2fa8971c15b9a082cddbb40dec Mon Sep 17 00:00:00 2001 From: cel 🌸 Date: Wed, 26 Mar 2025 15:29:11 +0000 Subject: refactor(filament): split logic into different files --- filamento/src/logic/abort.rs | 10 ++++++++++ 1 file changed, 10 insertions(+) create mode 100644 filamento/src/logic/abort.rs (limited to 'filamento/src/logic/abort.rs') diff --git a/filamento/src/logic/abort.rs b/filamento/src/logic/abort.rs new file mode 100644 index 0000000..32c4823 --- /dev/null +++ b/filamento/src/logic/abort.rs @@ -0,0 +1,10 @@ +use lampada::error::ReadError; + +use super::ClientLogic; + +pub async fn on_abort(logic: ClientLogic) { + let mut iqs = logic.pending().lock().await; + for (_id, sender) in iqs.drain() { + let _ = sender.send(Err(ReadError::LostConnection)); + } +} -- cgit