proxmox-mirrors/proxmox
1
0
Fork 1
mirror of https://git.proxmox.com/git/proxmox synced 2025-05-01 11:11:58 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

proxmox-async: clippy fixup

Browse Source 
Signed-off-by: Wolfgang Bumiller <w.bumiller@proxmox.com>
This commit is contained in:
Wolfgang Bumiller 2022-02-08 14:26:46 +01:00
parent 0b90f8d802
commit 9539fbde1c
1 changed files with 4 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
proxmox-async/src/stream/async_reader_stream.rs
View File

@ -8,6 +8,8 @@ use futures::ready;
use futures::stream::Stream; use futures::stream::Stream;
use tokio::io::{AsyncRead, ReadBuf}; use tokio::io::{AsyncRead, ReadBuf};
use proxmox_io::vec;
/// Wrapper struct to convert an [AsyncRead] into a [Stream] /// Wrapper struct to convert an [AsyncRead] into a [Stream]
pub struct AsyncReaderStream<R: AsyncRead + Unpin> { pub struct AsyncReaderStream<R: AsyncRead + Unpin> {
reader: R, reader: R,
@ -16,19 +18,11 @@ pub struct AsyncReaderStream<R: AsyncRead + Unpin> {
impl<R: AsyncRead + Unpin> AsyncReaderStream<R> { impl<R: AsyncRead + Unpin> AsyncReaderStream<R> {
pub fn new(reader: R) -> Self { pub fn new(reader: R) -> Self {
let mut buffer = Vec::with_capacity(64 * 1024); Self::with_buffer_size(reader, 64 * 1024)
unsafe {
buffer.set_len(buffer.capacity());
}
Self { reader, buffer }
} }
pub fn with_buffer_size(reader: R, buffer_size: usize) -> Self { pub fn with_buffer_size(reader: R, buffer_size: usize) -> Self {
let mut buffer = Vec::with_capacity(buffer_size); Self { reader, buffer: vec::undefined(buffer_size) }
unsafe {
buffer.set_len(buffer.capacity());
}
Self { reader, buffer }
} }
} }