diff options
Diffstat (limited to 'crates')
-rw-r--r-- | crates/ra_cargo_watch/src/lib.rs | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/crates/ra_cargo_watch/src/lib.rs b/crates/ra_cargo_watch/src/lib.rs index c67ec39d4..2692c1bf5 100644 --- a/crates/ra_cargo_watch/src/lib.rs +++ b/crates/ra_cargo_watch/src/lib.rs | |||
@@ -95,6 +95,9 @@ impl CheckWatcherThread { | |||
95 | } | 95 | } |
96 | 96 | ||
97 | fn run(&mut self, task_send: &Sender<CheckTask>, cmd_recv: &Receiver<CheckCommand>) { | 97 | fn run(&mut self, task_send: &Sender<CheckTask>, cmd_recv: &Receiver<CheckCommand>) { |
98 | // If we rerun the thread, we need to discard the previous check results first | ||
99 | self.clean_previous_results(task_send); | ||
100 | |||
98 | loop { | 101 | loop { |
99 | select! { | 102 | select! { |
100 | recv(&cmd_recv) -> cmd => match cmd { | 103 | recv(&cmd_recv) -> cmd => match cmd { |
@@ -127,6 +130,13 @@ impl CheckWatcherThread { | |||
127 | } | 130 | } |
128 | } | 131 | } |
129 | 132 | ||
133 | fn clean_previous_results(&self, task_send: &Sender<CheckTask>) { | ||
134 | task_send.send(CheckTask::ClearDiagnostics).unwrap(); | ||
135 | task_send | ||
136 | .send(CheckTask::Status(WorkDoneProgress::End(WorkDoneProgressEnd { message: None }))) | ||
137 | .unwrap(); | ||
138 | } | ||
139 | |||
130 | fn should_recheck(&mut self) -> bool { | 140 | fn should_recheck(&mut self) -> bool { |
131 | if let Some(_last_update_req) = &self.last_update_req { | 141 | if let Some(_last_update_req) = &self.last_update_req { |
132 | // We currently only request an update on save, as we need up to | 142 | // We currently only request an update on save, as we need up to |