Proxmox-Port/proxmox
1
0
Fork 0
forked from proxmox-mirrors/proxmox
Code Pull Requests Activity

minor cleanup

Browse Source 
Signed-off-by: Wolfgang Bumiller <w.bumiller@proxmox.com>
This commit is contained in:
Wolfgang Bumiller 2021-02-23 14:33:08 +01:00
parent 0d68daab86
commit 69a51c9af0
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
proxmox/src/test/io.rs
View File

@ -45,13 +45,13 @@ impl<R: std::io::Read + Unpin> AsyncRead for AsyncBlockingReader<R> {
) -> Poll<std::io::Result<()>> { ) -> Poll<std::io::Result<()>> {
let this = Pin::get_mut(self); let this = Pin::get_mut(self);
let mut read_buf = buf.initialize_unfilled(); let mut read_buf = buf.initialize_unfilled();
match this.inner.read(&mut read_buf) { Poll::Ready(match this.inner.read(&mut read_buf) {
Ok(len) => { Ok(len) => {
buf.advance(len); buf.advance(len);
Poll::Ready(Ok(())) Ok(())
}
Err(err) => Poll::Ready(Err(err)),
} }
Err(err) => Err(err),
})
} }
} }
@ -62,10 +62,10 @@ impl<R: std::io::Write + Unpin> AsyncWrite for AsyncBlockingWriter<R> {
buf: &[u8], buf: &[u8],
) -> Poll<std::io::Result<usize>> { ) -> Poll<std::io::Result<usize>> {
let this = Pin::get_mut(self); let this = Pin::get_mut(self);
match this.inner.write(buf) { Poll::Ready(match this.inner.write(buf) {
Ok(len) => Poll::Ready(Ok(len)), Ok(len) => Ok(len),
Err(err) => Poll::Ready(Err(err)), Err(err) => Err(err),
} })
} }
fn poll_flush(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<std::io::Result<()>> { fn poll_flush(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<std::io::Result<()>> {