try prost

ref: #173

Co-authored-by: jokemanfire <hu.dingyang@zte.com.cn>
Signed-off-by: Xuewei Niu <niuxuewei.nxw@antgroup.com>

Author: jokemanfire

src/sync/server.rs

@@ -33,7 +33,7 @@ use std::thread;
 use std::thread::JoinHandle;
 
 use super::utils::{response_error_to_channel, response_to_channel};
-use crate::context;
+use crate::{context, Status};
 use crate::error::{get_status, Error, Result};
 use crate::proto::{Code, MessageHeader, Request, Response, MESSAGE_TYPE_REQUEST};
 use crate::sync::channel::{read_message, write_message};
@@ -167,7 +167,7 @@ fn start_method_handler_thread(
             if mh.type_ != MESSAGE_TYPE_REQUEST {
                 continue;
             }
-            let mut req;
+            let req: Request = Request::default();
             #[cfg(not(feature = "prost"))]
             {
                 let mut s = CodedInputStream::from_bytes(&buf);
@@ -186,7 +186,6 @@ fn start_method_handler_thread(
             }
             #[cfg(feature = "prost")]
             {
-                req = Request::default();
                 if let Err(x) = req.merge(&buf as &[u8]) {
                     let status = get_status(Code::InvalidArgument, x.to_string());
                     let res = Response {