@@ -55,28 +55,26 @@ impl State {
55
55
if let Err ( ref err) = result {
56
56
if err. downcast_ref :: < LCError > ( ) . is_none ( ) {
57
57
error ! (
58
- "Error handling message: {}\n \n Message: {:?}\n \n Error: {:?}" ,
59
- err, method_call, err
58
+ "Error handling message: {}\n \n Message: {}\n \n Error: {:?}" ,
59
+ err,
60
+ serde_json:: to_string( & method_call) . unwrap_or_default( ) ,
61
+ err
60
62
) ;
61
63
}
62
64
}
63
- if let Err ( err) = self . output ( lang_id. as_deref ( ) , method_call. id , result) {
64
- error ! ( "Error writing output to vim: {:?}" , err) ;
65
- }
65
+ let _ = self . output ( lang_id. as_deref ( ) , method_call. id , result) ;
66
66
}
67
67
Call :: Notification ( lang_id, notification) => {
68
68
let result = self . handle_notification ( lang_id. as_deref ( ) , & notification) ;
69
69
if let Err ( ref err) = result {
70
70
if err. downcast_ref :: < LCError > ( ) . is_none ( ) {
71
71
error ! (
72
- "Error handling message: {}\n \n Message: {:?}\n \n Error: {:?}" ,
73
- err, notification, err
72
+ "Error handling message: {}\n \n Message: {}\n \n Error: {:?}" ,
73
+ err,
74
+ serde_json:: to_string( & notification) . unwrap_or_default( ) ,
75
+ err
74
76
) ;
75
77
}
76
-
77
- if let Err ( err) = self . echowarn ( format ! ( "{}" , err) ) {
78
- error ! ( "Error making request to vim: {:?}" , err) ;
79
- }
80
78
}
81
79
}
82
80
}
@@ -87,6 +85,7 @@ impl State {
87
85
88
86
/// Send message to RPC server.
89
87
fn write ( & mut self , languageId : Option < & str > , message : & str ) -> Result < ( ) > {
88
+ info ! ( "=> {:?} {}" , languageId, message) ;
90
89
if let Some ( languageId) = languageId {
91
90
let writer = self . writers
92
91
. get_mut ( languageId)
@@ -124,7 +123,6 @@ impl State {
124
123
} ;
125
124
126
125
let message = serde_json:: to_string ( & method_call) ?;
127
- info ! ( "=> {}" , message) ;
128
126
self . write ( languageId, & message) ?;
129
127
130
128
match self . poll_output ( id) ? {
@@ -145,7 +143,6 @@ impl State {
145
143
} ;
146
144
147
145
let message = serde_json:: to_string ( & notification) ?;
148
- info ! ( "=> {}" , message) ;
149
146
self . write ( languageId, & message) ?;
150
147
151
148
Ok ( ( ) )
@@ -172,7 +169,6 @@ impl State {
172
169
} ;
173
170
174
171
let message = serde_json:: to_string ( & response) ?;
175
- info ! ( "=> {}" , message) ;
176
172
self . write ( languageId, & message) ?;
177
173
Ok ( ( ) )
178
174
}
@@ -347,7 +343,7 @@ pub fn loop_reader<T: BufRead>(
347
343
if message. is_empty ( ) {
348
344
continue ;
349
345
}
350
- info ! ( "<= {}" , message) ;
346
+ info ! ( "<= {:?} {}" , languageId , message) ;
351
347
// let message = message.replace(r#","meta":{}"#, "");
352
348
let message: RawMessage = serde_json:: from_str ( message) ?;
353
349
let message = match message {
0 commit comments