Fix error message when connection's IO loop exits before message loop

Max Brunsfeld created 4 years ago

Change summary

zrpc/src/peer.rs | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)

Detailed changes

zrpc/src/peer.rs

@@ -227,7 +227,8 @@ impl Peer {
             connection
                 .outgoing_tx
                 .send(request.into_envelope(message_id, None, original_sender_id.map(|id| id.0)))
-                .await?;
+                .await
+                .map_err(|_| anyhow!("connection was closed"))?;
             let response = rx
                 .recv()
                 .await