diff options
Diffstat (limited to 'test_util')
| -rw-r--r-- | test_util/src/lib.rs | 26 |
1 files changed, 16 insertions, 10 deletions
diff --git a/test_util/src/lib.rs b/test_util/src/lib.rs index 41fb96a1b..cf66e3366 100644 --- a/test_util/src/lib.rs +++ b/test_util/src/lib.rs @@ -1228,11 +1228,14 @@ async fn main_server( let body = hyper::body::to_bytes(req.into_body()) .await .unwrap_or_default(); - let Ok(body): Result<SnapshotRead, _> = prost::Message::decode(&body[..]) else { - return Ok(Response::builder() - .status(StatusCode::BAD_REQUEST) - .body(Body::empty()) - .unwrap()); + let Ok(body): Result<SnapshotRead, _> = prost::Message::decode(&body[..]) + else { + return Ok( + Response::builder() + .status(StatusCode::BAD_REQUEST) + .body(Body::empty()) + .unwrap(), + ); }; if body.ranges.is_empty() { return Ok( @@ -1280,11 +1283,14 @@ async fn main_server( let body = hyper::body::to_bytes(req.into_body()) .await .unwrap_or_default(); - let Ok(_body): Result<AtomicWrite, _> = prost::Message::decode(&body[..]) else { - return Ok(Response::builder() - .status(StatusCode::BAD_REQUEST) - .body(Body::empty()) - .unwrap()); + let Ok(_body): Result<AtomicWrite, _> = prost::Message::decode(&body[..]) + else { + return Ok( + Response::builder() + .status(StatusCode::BAD_REQUEST) + .body(Body::empty()) + .unwrap(), + ); }; Ok( Response::builder() |