Skip to content

Commit 0afa215

Browse files
committed
fix(error): classify read timeout as body error
1 parent a8a27c9 commit 0afa215

2 files changed

Lines changed: 3 additions & 3 deletions

File tree

src/client/layer/timeout/body.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -215,7 +215,7 @@ where
215215
// Error if the timeout has expired.
216216
if let Some(sleep) = this.sleep.as_mut().as_pin_mut() {
217217
if sleep.poll(cx).is_ready() {
218-
return Poll::Ready(Some(Err(Box::new(TimedOut))));
218+
return Poll::Ready(Some(Err(Error::body(TimedOut).into())));
219219
}
220220
}
221221

tests/timeouts.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -162,7 +162,7 @@ async fn response_timeout() {
162162
let res = client.get(&url).send().await.expect("Failed to get");
163163
let err = res.text().await.unwrap_err();
164164

165-
assert!(err.is_timeout());
165+
assert!(err.is_body() && err.is_timeout());
166166
}
167167

168168
#[tokio::test]
@@ -218,7 +218,7 @@ async fn read_timeout_applies_to_body() {
218218
let res = client.get(&url).send().await.expect("Failed to get");
219219
let err = res.text().await.unwrap_err();
220220

221-
assert!(err.is_timeout());
221+
assert!(err.is_body() && err.is_timeout());
222222
}
223223

224224
#[cfg(feature = "stream")]

0 commit comments

Comments
 (0)