close request receiving channel on errors immediately

google · Jan 11, 2024 · 876fd47 · 876fd47
1 parent 006a9f3
commit 876fd47
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/tarpc/src/client.rs b/tarpc/src/client.rs
@@ -352,6 +352,7 @@ where
                     let _entered = span.enter();
                     tracing::info!("ReceiveError");
                 }
+                self.pending_requests_mut().close();
                 ChannelError::Read(e)
             })
             .map_ok(|response| {