filamento/src/logic/abort.rs


1
2
3
4
5
6
7
8
9
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));
    }
}