diff --git a/proxmox/src/test/io.rs b/proxmox/src/test/io.rs index d8b6a984..6e4a2782 100644 --- a/proxmox/src/test/io.rs +++ b/proxmox/src/test/io.rs @@ -9,9 +9,7 @@ pub struct AsyncBlockingReader { impl AsyncBlockingReader { pub fn new(inner: W) -> Self { - Self { - inner - } + Self { inner } } pub fn inner(&self) -> &W { @@ -26,10 +24,7 @@ pub struct AsyncBlockingWriter { impl AsyncBlockingWriter { pub fn new(inner: W) -> Self { - Self { - inner, - seek_pos: 0, - } + Self { inner, seek_pos: 0 } } pub fn inner(&self) -> &W { @@ -85,10 +80,7 @@ impl AsyncSeek for AsyncBlockingWriter { Ok(()) } - fn poll_complete( - self: Pin<&mut Self>, - _cx: &mut Context<'_>, - ) -> Poll> { + fn poll_complete(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll> { let this = Pin::get_mut(self); Poll::Ready(Ok(this.seek_pos)) } diff --git a/proxmox/src/test/task.rs b/proxmox/src/test/task.rs index 4f5eca6d..62c22f39 100644 --- a/proxmox/src/test/task.rs +++ b/proxmox/src/test/task.rs @@ -12,7 +12,7 @@ where unsafe { match Pin::new_unchecked(&mut fut).poll(&mut cx) { Poll::Pending => Err(crate::sys::error::io_err_other( - "got Poll::Pending synchronous context", + "got Poll::Pending synchronous context", )), Poll::Ready(r) => r, } @@ -20,7 +20,7 @@ where } const WAKER_VTABLE: std::task::RawWakerVTable = -std::task::RawWakerVTable::new(forbid_clone, forbid_wake, forbid_wake, ignore_drop); + std::task::RawWakerVTable::new(forbid_clone, forbid_wake, forbid_wake, ignore_drop); unsafe fn forbid_clone(_: *const ()) -> std::task::RawWaker { panic!("tried to clone waker for synchronous task");