berkus
/
actix-web
mirror of https://github.com/fafhrd91/actix-web
1
0
Fork 0
Code Issues Releases Wiki Activity

fix clippy warning

This commit is contained in:
fakeshadow 2021-10-17 04:10:15 +08:00
parent a751be73cc
commit 5d3d1fb20e
1 changed files with 11 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
actix-files/src/chunked.rs
View File

@ -92,25 +92,23 @@ fn chunked_read_file_callback(
} }
#[cfg(feature = "io-uring")] #[cfg(feature = "io-uring")]
fn chunked_read_file_callback( async fn chunked_read_file_callback(
file: File, file: File,
offset: u64, offset: u64,
max_bytes: usize, max_bytes: usize,
) -> impl Future<Output = io::Result<(File, Bytes)>> { ) -> io::Result<(File, Bytes)> {
async move { let buf = Vec::with_capacity(max_bytes);
let buf = Vec::with_capacity(max_bytes);
let (res, mut buf) = file.read_at(buf, offset).await; let (res, mut buf) = file.read_at(buf, offset).await;
let n_bytes = res?; let n_bytes = res?;
if n_bytes == 0 { if n_bytes == 0 {
return Err(io::ErrorKind::UnexpectedEof.into()); return Err(io::ErrorKind::UnexpectedEof.into());
}
let _ = buf.split_off(n_bytes);
Ok((file, Bytes::from(buf)))
} }
let _ = buf.split_off(n_bytes);
Ok((file, Bytes::from(buf)))
} }
#[cfg(feature = "io-uring")] #[cfg(feature = "io-uring")]