aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--crates/rust-analyzer/src/main_loop.rs12
1 files changed, 7 insertions, 5 deletions
diff --git a/crates/rust-analyzer/src/main_loop.rs b/crates/rust-analyzer/src/main_loop.rs
index 740c52e21..7a81db3d9 100644
--- a/crates/rust-analyzer/src/main_loop.rs
+++ b/crates/rust-analyzer/src/main_loop.rs
@@ -243,7 +243,8 @@ pub fn main_loop(config: Config, connection: Connection) -> Result<()> {
243#[derive(Debug)] 243#[derive(Debug)]
244enum Task { 244enum Task {
245 Respond(Response), 245 Respond(Response),
246 SendMessage(Message), 246 Notify(Notification),
247 SendRequest(Request),
247 Diagnostic(DiagnosticTask), 248 Diagnostic(DiagnosticTask),
248} 249}
249 250
@@ -275,7 +276,7 @@ impl fmt::Debug for Event {
275 return debug_verbose_not(not, f); 276 return debug_verbose_not(not, f);
276 } 277 }
277 } 278 }
278 Event::Task(Task::SendMessage(Message::Notification(not))) => { 279 Event::Task(Task::Notify(not)) => {
279 if notification_is::<lsp_types::notification::PublishDiagnostics>(not) { 280 if notification_is::<lsp_types::notification::PublishDiagnostics>(not) {
280 return debug_verbose_not(not, f); 281 return debug_verbose_not(not, f);
281 } 282 }
@@ -463,7 +464,7 @@ fn on_progress_report(
463 token: lsp_types::ProgressToken::String(token.to_string()), 464 token: lsp_types::ProgressToken::String(token.to_string()),
464 }, 465 },
465 ); 466 );
466 task_sender.send(Task::SendMessage(create_progress_req.into())).unwrap(); 467 task_sender.send(Task::SendRequest(create_progress_req.into())).unwrap();
467 }; 468 };
468 469
469 let (token, progress) = match report { 470 let (token, progress) = match report {
@@ -526,7 +527,7 @@ fn on_progress_report(
526 value: lsp_types::ProgressParamsValue::WorkDone(progress), 527 value: lsp_types::ProgressParamsValue::WorkDone(progress),
527 }; 528 };
528 let not = notification_new::<lsp_types::notification::Progress>(params); 529 let not = notification_new::<lsp_types::notification::Progress>(params);
529 task_sender.send(Task::SendMessage(not.into())).unwrap() 530 task_sender.send(Task::Notify(not.into())).unwrap()
530} 531}
531 532
532fn on_task( 533fn on_task(
@@ -543,7 +544,8 @@ fn on_task(
543 msg_sender.send(response.into()).unwrap(); 544 msg_sender.send(response.into()).unwrap();
544 } 545 }
545 } 546 }
546 Task::SendMessage(msg) => msg_sender.send(msg).unwrap(), 547 Task::Notify(not) => msg_sender.send(not.into()).unwrap(),
548 Task::SendRequest(req) => msg_sender.send(req.into()).unwrap(),
547 Task::Diagnostic(task) => on_diagnostic_task(task, msg_sender, state), 549 Task::Diagnostic(task) => on_diagnostic_task(task, msg_sender, state),
548 } 550 }
549} 551}