Skip to content

Commit 29fa629

Browse files
so far
1 parent 01dfd06 commit 29fa629

File tree

2 files changed

+81
-15
lines changed

2 files changed

+81
-15
lines changed

Cargo.lock

Lines changed: 71 additions & 3 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

crates/pg_lsp/src/server.rs

Lines changed: 10 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -758,7 +758,7 @@ impl Server {
758758
});
759759
}
760760

761-
fn refresh_schema_cache(&self) {
761+
async fn refresh_schema_cache(&self) {
762762
if self.db_conn.is_none() {
763763
return;
764764
}
@@ -767,17 +767,15 @@ impl Server {
767767
let conn = self.db_conn.as_ref().unwrap().pool.clone();
768768
let client = self.client.clone();
769769

770-
async_std::task::spawn(async move {
771-
client
772-
.send_notification::<ShowMessage>(ShowMessageParams {
773-
typ: lsp_types::MessageType::INFO,
774-
message: "Refreshing schema cache...".to_string(),
775-
})
776-
.unwrap();
777-
let schema_cache = SchemaCache::load(&conn).await;
778-
tx.send(InternalMessage::SetSchemaCache(schema_cache))
779-
.unwrap();
780-
});
770+
client
771+
.send_notification::<ShowMessage>(ShowMessageParams {
772+
typ: lsp_types::MessageType::INFO,
773+
message: "Refreshing schema cache...".to_string(),
774+
})
775+
.unwrap();
776+
let schema_cache = SchemaCache::load(&conn).await;
777+
tx.send(InternalMessage::SetSchemaCache(schema_cache))
778+
.unwrap();
781779
}
782780

783781
fn did_change_configuration(

0 commit comments

Comments
 (0)