forked/hyper
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

style(http1): correct indentation

Browse Source 
Minor reformatting of single block.
This commit is contained in:
Rajin Gill
2021-12-14 00:23:58 -08:00
committed by Sean McArthur
parent e8cccce0c1
commit f44f7265e0
1 changed files with 12 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
src/proto/h1/role.rs
View File

@@ -76,21 +76,22 @@ where
#[cfg(all(feature = "server", feature = "runtime"))] #[cfg(all(feature = "server", feature = "runtime"))]
if !*ctx.h1_header_read_timeout_running { if !*ctx.h1_header_read_timeout_running {
if let Some(h1_header_read_timeout) = ctx.h1_header_read_timeout { if let Some(h1_header_read_timeout) = ctx.h1_header_read_timeout {
let deadline = Instant::now() + h1_header_read_timeout; let deadline = Instant::now() + h1_header_read_timeout;
match ctx.h1_header_read_timeout_fut { match ctx.h1_header_read_timeout_fut {
Some(h1_header_read_timeout_fut) => { Some(h1_header_read_timeout_fut) => {
debug!("resetting h1 header read timeout timer"); debug!("resetting h1 header read timeout timer");
h1_header_read_timeout_fut.as_mut().reset(deadline); h1_header_read_timeout_fut.as_mut().reset(deadline);
}, }
None => { None => {
debug!("setting h1 header read timeout timer"); debug!("setting h1 header read timeout timer");
*ctx.h1_header_read_timeout_fut = Some(Box::pin(tokio::time::sleep_until(deadline))); *ctx.h1_header_read_timeout_fut =
Some(Box::pin(tokio::time::sleep_until(deadline)));
}
} }
} }
} }
}
T::parse(bytes, ctx) T::parse(bytes, ctx)
} }