@@ -197,7 +197,7 @@ impl GlobalState {
197
197
let was_quiescent = self . is_quiescent ( ) ;
198
198
match event {
199
199
Event :: Lsp ( msg) => match msg {
200
- lsp_server:: Message :: Request ( req) => self . on_request ( loop_start, req) ,
200
+ lsp_server:: Message :: Request ( req) => self . on_new_request ( loop_start, req) ,
201
201
lsp_server:: Message :: Notification ( not) => {
202
202
self . on_notification ( not) ?;
203
203
}
@@ -209,7 +209,7 @@ impl GlobalState {
209
209
loop {
210
210
match task {
211
211
Task :: Response ( response) => self . respond ( response) ,
212
- Task :: Retry ( req) => self . on_request ( loop_start , req) ,
212
+ Task :: Retry ( req) => self . on_request ( req) ,
213
213
Task :: Diagnostics ( diagnostics_per_file) => {
214
214
for ( file_id, diagnostics) in diagnostics_per_file {
215
215
self . diagnostics . set_native_diagnostics ( file_id, diagnostics)
@@ -555,9 +555,12 @@ impl GlobalState {
555
555
Ok ( ( ) )
556
556
}
557
557
558
- fn on_request ( & mut self , request_received : Instant , req : Request ) {
558
+ fn on_new_request ( & mut self , request_received : Instant , req : Request ) {
559
559
self . register_request ( & req, request_received) ;
560
+ self . on_request ( req) ;
561
+ }
560
562
563
+ fn on_request ( & mut self , req : Request ) {
561
564
if self . shutdown_requested {
562
565
self . respond ( lsp_server:: Response :: new_err (
563
566
req. id ,
0 commit comments