qlue-ls 3.1.1

A language server for SPARQL
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

use futures::lock::Mutex;
use std::rc::Rc;

use crate::server::{
    Server,
    lsp::{CancelQueryNotification, errors::LSPError},
};

#[tracing::instrument(skip_all, fields(query_id = %notification.params.query_id))]
pub(super) async fn handle_cancel_notification(
    server_rc: Rc<Mutex<Server>>,
    notification: CancelQueryNotification,
) -> Result<(), LSPError> {
    let mut server = server_rc.lock().await;
    if let Some(abort_fn) = server
        .state
        .get_running_request(&notification.params.query_id)
    {
        abort_fn();
    } else {
        tracing::error!(
            "Received cancel notification for unknown query: {}",
            notification.params.query_id
        );
    }
    Ok(())
}