We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1e5b129 commit 98b8bf3Copy full SHA for 98b8bf3
src/asynchronous/server.rs
@@ -310,6 +310,7 @@ async fn handle_request(
310
}
311
trace!("Got Message request {:?}", req);
312
313
+ let stream_id = header.stream_id;
314
let path = format!("/{}/{}", req.service, req.method);
315
if let Some(x) = methods.get(&path) {
316
let method = x;
@@ -327,6 +328,10 @@ async fn handle_request(
327
328
329
Err(e) => {
330
error!("method handle {} get error {:?}", path, e);
331
+ let status = get_status(Code::UNKNOWN, e);
332
+ if let Err(e) = respond_with_status(tx, stream_id, status).await {
333
+ error!("respond get error {:?}", e);
334
+ }
335
336
337
} else {
0 commit comments