diff options
| author |  cel 🌸 <cel@bunny.garden> | 2025-03-27 19:09:35 +0000 |
|---|---|---|
| committer | cel 🌸 <cel@bunny.garden> | 2025-03-27 19:09:35 +0000 |
| commit | a367aca33fecc03270b5b9ad2a6a21281d760fd8 (patch) | |
| tree | 695270823ee5d55f483875580c509fb2c300bd26 /filamento/src/logic/abort.rs | |
| parent | 83a6aa0574190137b38331bd53795324139237cf (diff) | |
| download | luz-a367aca33fecc03270b5b9ad2a6a21281d760fd8.tar.gz luz-a367aca33fecc03270b5b9ad2a6a21281d760fd8.tar.bz2 luz-a367aca33fecc03270b5b9ad2a6a21281d760fd8.zip | |
refactor(filamento): handle_online logic
Diffstat (limited to 'filamento/src/logic/abort.rs')
| -rw-r--r-- | filamento/src/logic/abort.rs | 5 |
1 files changed, 1 insertions, 4 deletions
diff --git a/filamento/src/logic/abort.rs b/filamento/src/logic/abort.rs index 32c4823..df82655 100644 --- a/filamento/src/logic/abort.rs +++ b/filamento/src/logic/abort.rs @@ -3,8 +3,5 @@ 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)); - } + logic.pending().drain().await; } |