Remove unneeded send method

mo8it · mo8it · commit 7341b88e6f1f · 2024-08-09T23:59:42.000+02:00
diff --git a/src/tools/rust-analyzer/crates/rust-analyzer/src/flycheck.rs b/src/tools/rust-analyzer/crates/rust-analyzer/src/flycheck.rs
@@ -256,7 +256,7 @@ impl FlycheckActor {
     }
 
     fn report_progress(&self, progress: Progress) {
-        self.send(FlycheckMessage::Progress { id: self.id, progress });
+        self.sender.send(FlycheckMessage::Progress { id: self.id, progress }).unwrap();
     }
 
     fn next_event(&self, inbox: &Receiver<StateChange>) -> Option<Event> {
@@ -329,7 +329,9 @@ impl FlycheckActor {
                         );
                     }
                     if self.status == FlycheckStatus::Started {
-                        self.send(FlycheckMessage::ClearDiagnostics { id: self.id });
+                        self.sender
+                            .send(FlycheckMessage::ClearDiagnostics { id: self.id })
+                            .unwrap();
                     }
                     self.report_progress(Progress::DidFinish(res));
                     self.status = FlycheckStatus::Finished;
@@ -351,13 +353,17 @@ impl FlycheckActor {
                             "diagnostic received"
                         );
                         if self.status == FlycheckStatus::Started {
-                            self.send(FlycheckMessage::ClearDiagnostics { id: self.id });
+                            self.sender
+                                .send(FlycheckMessage::ClearDiagnostics { id: self.id })
+                                .unwrap();
                         }
-                        self.send(FlycheckMessage::AddDiagnostic {
-                            id: self.id,
-                            workspace_root: self.root.clone(),
-                            diagnostic: msg,
-                        });
+                        self.sender
+                            .send(FlycheckMessage::AddDiagnostic {
+                                id: self.id,
+                                workspace_root: self.root.clone(),
+                                diagnostic: msg,
+                            })
+                            .unwrap();
                         self.status = FlycheckStatus::DiagnosticSent;
                     }
                 },
@@ -477,10 +483,6 @@ impl FlycheckActor {
         cmd.args(args);
         Some(cmd)
     }
-
-    fn send(&self, check_task: FlycheckMessage) {
-        self.sender.send(check_task).unwrap();
-    }
 }
 
 #[allow(clippy::large_enum_variant)]
diff --git a/src/tools/rust-analyzer/crates/rust-analyzer/src/global_state.rs b/src/tools/rust-analyzer/crates/rust-analyzer/src/global_state.rs
@@ -504,7 +504,7 @@ impl GlobalState {
         handler: ReqHandler,
     ) {
         let request = self.req_queue.outgoing.register(R::METHOD.to_owned(), params, handler);
-        self.send(request.into());
+        self.sender.send(request.into()).unwrap();
     }
 
     pub(crate) fn complete_request(&mut self, response: lsp_server::Response) {
@@ -521,7 +521,7 @@ impl GlobalState {
         params: N::Params,
     ) {
         let not = lsp_server::Notification::new(N::METHOD.to_owned(), params);
-        self.send(not.into());
+        self.sender.send(not.into()).unwrap();
     }
 
     pub(crate) fn register_request(
@@ -544,24 +544,20 @@ impl GlobalState {
 
             let duration = start.elapsed();
             tracing::debug!("handled {} - ({}) in {:0.2?}", method, response.id, duration);
-            self.send(response.into());
+            self.sender.send(response.into()).unwrap();
         }
     }
 
     pub(crate) fn cancel(&mut self, request_id: lsp_server::RequestId) {
         if let Some(response) = self.req_queue.incoming.cancel(request_id) {
-            self.send(response.into());
+            self.sender.send(response.into()).unwrap();
         }
     }
 
     pub(crate) fn is_completed(&self, request: &lsp_server::Request) -> bool {
         self.req_queue.incoming.is_completed(&request.id)
     }
 
-    fn send(&self, message: lsp_server::Message) {
-        self.sender.send(message).unwrap()
-    }
-
     pub(crate) fn publish_diagnostics(
         &mut self,
         uri: Url,
diff --git a/src/tools/rust-analyzer/crates/vfs-notify/src/lib.rs b/src/tools/rust-analyzer/crates/vfs-notify/src/lib.rs
@@ -180,17 +180,19 @@ impl NotifyActor {
                                 }
                             }
                         }
-                        self.send(loader::Message::Progress {
-                            n_total,
-                            n_done: LoadingProgress::Finished,
-                            config_version,
-                            dir: None,
-                        });
+                        self.sender
+                            .send(loader::Message::Progress {
+                                n_total,
+                                n_done: LoadingProgress::Finished,
+                                config_version,
+                                dir: None,
+                            })
+                            .unwrap();
                     }
                     Message::Invalidate(path) => {
                         let contents = read(path.as_path());
                         let files = vec![(path, contents)];
-                        self.send(loader::Message::Changed { files });
+                        self.sender.send(loader::Message::Changed { files }).unwrap();
                     }
                 },
                 Event::NotifyEvent(event) => {
@@ -238,7 +240,7 @@ impl NotifyActor {
                                     Some((path, contents))
                                 })
                                 .collect();
-                            self.send(loader::Message::Changed { files });
+                            self.sender.send(loader::Message::Changed { files }).unwrap();
                         }
                     }
                 }
@@ -322,10 +324,6 @@ impl NotifyActor {
             log_notify_error(watcher.watch(path, RecursiveMode::NonRecursive));
         }
     }
-
-    fn send(&self, msg: loader::Message) {
-        self.sender.send(msg).unwrap();
-    }
 }
 
 fn read(path: &AbsPath) -> Option<Vec<u8>> {

Original file line number	Diff line number	Diff line change
`@@ -504,7 +504,7 @@ impl GlobalState {`
`504`	`504`	`handler: ReqHandler,`
`505`	`505`	`) {`
`506`	`506`	`let request = self.req_queue.outgoing.register(R::METHOD.to_owned(), params, handler);`
`507`		`- self.send(request.into());`
	`507`	`+ self.sender.send(request.into()).unwrap();`
`508`	`508`	`}`
`509`	`509`
`510`	`510`	`pub(crate) fn complete_request(&mut self, response: lsp_server::Response) {`
`@@ -521,7 +521,7 @@ impl GlobalState {`
`521`	`521`	`params: N::Params,`
`522`	`522`	`) {`
`523`	`523`	`let not = lsp_server::Notification::new(N::METHOD.to_owned(), params);`
`524`		`- self.send(not.into());`
	`524`	`+ self.sender.send(not.into()).unwrap();`
`525`	`525`	`}`
`526`	`526`
`527`	`527`	`pub(crate) fn register_request(`
`@@ -544,24 +544,20 @@ impl GlobalState {`
`544`	`544`
`545`	`545`	`let duration = start.elapsed();`
`546`	`546`	`tracing::debug!("handled {} - ({}) in {:0.2?}", method, response.id, duration);`
`547`		`- self.send(response.into());`
	`547`	`+ self.sender.send(response.into()).unwrap();`
`548`	`548`	`}`
`549`	`549`	`}`
`550`	`550`
`551`	`551`	`pub(crate) fn cancel(&mut self, request_id: lsp_server::RequestId) {`
`552`	`552`	`if let Some(response) = self.req_queue.incoming.cancel(request_id) {`
`553`		`- self.send(response.into());`
	`553`	`+ self.sender.send(response.into()).unwrap();`
`554`	`554`	`}`
`555`	`555`	`}`
`556`	`556`
`557`	`557`	`pub(crate) fn is_completed(&self, request: &lsp_server::Request) -> bool {`
`558`	`558`	`self.req_queue.incoming.is_completed(&request.id)`
`559`	`559`	`}`
`560`	`560`
`561`		`- fn send(&self, message: lsp_server::Message) {`
`562`		`- self.sender.send(message).unwrap()`
`563`		`- }`
`564`		`-`
`565`	`561`	`pub(crate) fn publish_diagnostics(`
`566`	`562`	`&mut self,`
`567`	`563`	`uri: Url,`
Original file line number	Diff line number	Diff line change
`@@ -180,17 +180,19 @@ impl NotifyActor {`
`180`	`180`	`}`
`181`	`181`	`}`
`182`	`182`	`}`
`183`		`- self.send(loader::Message::Progress {`
`184`		`- n_total,`
`185`		`- n_done: LoadingProgress::Finished,`
`186`		`- config_version,`
`187`		`- dir: None,`
`188`		`- });`
	`183`	`+ self.sender`
	`184`	`+ .send(loader::Message::Progress {`
	`185`	`+ n_total,`
	`186`	`+ n_done: LoadingProgress::Finished,`
	`187`	`+ config_version,`
	`188`	`+ dir: None,`
	`189`	`+ })`
	`190`	`+ .unwrap();`
`189`	`191`	`}`
`190`	`192`	`Message::Invalidate(path) => {`
`191`	`193`	`let contents = read(path.as_path());`
`192`	`194`	`let files = vec![(path, contents)];`
`193`		`- self.send(loader::Message::Changed { files });`
	`195`	`+ self.sender.send(loader::Message::Changed { files }).unwrap();`
`194`	`196`	`}`
`195`	`197`	`},`
`196`	`198`	`Event::NotifyEvent(event) => {`
`@@ -238,7 +240,7 @@ impl NotifyActor {`
`238`	`240`	`Some((path, contents))`
`239`	`241`	`})`
`240`	`242`	`.collect();`
`241`		`- self.send(loader::Message::Changed { files });`
	`243`	`+ self.sender.send(loader::Message::Changed { files }).unwrap();`
`242`	`244`	`}`
`243`	`245`	`}`
`244`	`246`	`}`
`@@ -322,10 +324,6 @@ impl NotifyActor {`
`322`	`324`	`log_notify_error(watcher.watch(path, RecursiveMode::NonRecursive));`
`323`	`325`	`}`
`324`	`326`	`}`
`325`		`-`
`326`		`- fn send(&self, msg: loader::Message) {`
`327`		`- self.sender.send(msg).unwrap();`
`328`		`- }`
`329`	`327`	`}`
`330`	`328`
`331`	`329`	`fn read(path: &AbsPath) -> Option<Vec<u8>> {`