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));
    }
}