kc/helix
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Retry on cancelled request

Browse source
This commit is contained in:
Sofus Addington 2025-03-06 16:55:19 +01:00
parent b8f47d7ca9
commit a9c2953001
No known key found for this signature in database
GPG key ID: 57579341E1199840
1 changed files with 28 additions and 2 deletions

30
helix-term/src/handlers/diagnostics.rs
View file

@ -177,7 +177,8 @@ pub fn pull_diagnostics_for_document(
}
});
let provider = DiagnosticProvider::from_server_and_identifier(language_server.id(), identifier);
let language_server_id = language_server.id();
let provider = DiagnosticProvider::from_server_and_identifier(language_server_id, identifier);
let document_id = doc.id();
tokio::spawn(async move {
@ -193,7 +194,32 @@ pub fn pull_diagnostics_for_document(
})
.await
}
Err(err) => log::error!("Pull diagnostic request failed: {err}"),
Err(err) => {
let parsed_cancellation_data = if let helix_lsp::Error::Rpc(error) = err {
error.data.and_then(|data| {
serde_json::from_value::<lsp::DiagnosticServerCancellationData>(data).ok()
})
} else {
log::error!("Pull diagnostic request failed: {err}");
return;
};
if let Some(parsed_cancellation_data) = parsed_cancellation_data {
if parsed_cancellation_data.retrigger_request {
tokio::time::sleep(Duration::from_millis(500)).await;
job::dispatch(move |editor, _| {
if let (Some(doc), Some(language_server)) = (
editor.document(document_id),
editor.language_server_by_id(language_server_id),
) {
pull_diagnostics_for_document(doc, language_server);
}
})
.await;
}
}
}
}
});
}