clean up linting

Author: juleswritescode

crates/pg_lsp/src/server.rs

@@ -722,7 +722,7 @@ impl Server {
             self.pull_options();
         } else {
             let options = self.client.parse_options(params.settings)?;
-            self.update_db_connection(options);
+            self.update_db_connection(options)?;
         }
 
         Ok(())
@@ -770,8 +770,7 @@ impl Server {
             Message::Notification(notification) => {
                 dispatch::NotificationDispatcher::new(notification)
                     .on::<DidChangeConfiguration, _>(|params| {
-                        self.did_change_configuration(params);
-                        Ok(())
+                        self.did_change_configuration(params)
                     })?
                     .on::<DidCloseTextDocument, _>(|params| self.did_close(params))?
                     .on::<DidOpenTextDocument, _>(|params| self.did_open(params))?

crates/pg_lsp/src/server/debouncer/thread.rs

@@ -8,7 +8,6 @@ use super::buffer::{EventBuffer, Get, State};
 struct DebouncerThread<B> {
     mutex: Arc<Mutex<B>>,
     thread: JoinHandle<()>,
-    stopped: Arc<AtomicBool>,
 }
 
 impl<B> DebouncerThread<B> {
@@ -36,14 +35,8 @@ impl<B> DebouncerThread<B> {
         Self {
             mutex,
             thread,
-            stopped,
         }
     }
-
-    fn stop(self) -> JoinHandle<()> {
-        self.stopped.store(true, Ordering::Relaxed);
-        self.thread
-    }
 }
 
 /// Threaded debouncer wrapping [EventBuffer]. Accepts a common delay and a
@@ -68,13 +61,6 @@ impl<T> EventDebouncer<T> {
     pub fn clear(&self) {
         self.0.mutex.lock().unwrap().clear();
     }
-
-    /// Signals the debouncer thread to quit and returns a
-    /// [std::thread::JoinHandle] which can be `.join()`ed in the consumer
-    /// thread. The common idiom is: `debouncer.stop().join().unwrap();`
-    pub fn stop(self) -> JoinHandle<()> {
-        self.0.stop()
-    }
 }
 
 #[cfg(test)]