diff --git a/tarpc/src/client.rs b/tarpc/src/client.rs index 46bf562f..30ba70ec 100644 --- 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| {