lsp response fix

This commit is contained in:
Dongdong Zhou 2022-11-20 20:10:51 +00:00
parent 72f8057465
commit 4c71fdd5eb
1 changed files with 5 additions and 3 deletions

View File

@ -184,7 +184,7 @@ fn new(
let mut writer = Box::new(BufWriter::new(stdin));
let (io_tx, io_rx) = crossbeam_channel::unbounded();
let server_rpc = PluginServerRpcHandler::new(volt_id.clone(), io_tx);
let server_rpc = PluginServerRpcHandler::new(volt_id.clone(), io_tx.clone());
thread::spawn(move || {
for msg in io_rx {
if let Ok(msg) = serde_json::to_string(&msg) {
@ -203,10 +203,12 @@ fn new(
loop {
match read_message(&mut reader) {
Ok(message_str) => {
handle_plugin_server_message(
if let Some(resp) = handle_plugin_server_message(
&local_server_rpc,
&message_str,
);
) {
let _ = io_tx.send(resp);
}
}
Err(_err) => {
core_rpc.log(