We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 3eb3537 commit fa5374bCopy full SHA for fa5374b
1 file changed
src/agent-client-protocol/src/rpc.rs
@@ -285,11 +285,11 @@ where
285
spawn(
286
async move {
287
let result = handler.handle_request(request).await;
288
- outgoing_tx
289
- .unbounded_send(OutgoingMessage::Response(Response::new(
290
- id, result,
291
- )))
292
- .ok();
+ if let Err(e) = outgoing_tx.unbounded_send(
+ OutgoingMessage::Response(Response::new(id, result)),
+ ) {
+ log::error!("failed to send response to peer: {e:?}");
+ }
293
}
294
.boxed_local(),
295
);
0 commit comments