diff --git a/proxmox/src/tools/websocket.rs b/proxmox/src/tools/websocket.rs index 57e25919..83679b65 100644 --- a/proxmox/src/tools/websocket.rs +++ b/proxmox/src/tools/websocket.rs @@ -16,7 +16,7 @@ use hyper::header::{ SEC_WEBSOCKET_PROTOCOL, SEC_WEBSOCKET_VERSION, UPGRADE, }; use hyper::{Body, Response, StatusCode}; -use tokio::io::{AsyncRead, AsyncReadExt, AsyncWrite, AsyncWriteExt, ReadBuf}; +use tokio::io::{AsyncRead, AsyncWrite, AsyncWriteExt, ReadBuf}; use tokio::sync::mpsc; use futures::future::FutureExt; @@ -485,7 +485,7 @@ pub struct WebSocketReader { state: ReaderState, } -impl WebSocketReader { +impl WebSocketReader { /// Creates a new WebSocketReader with the given CallBack for control frames /// and a default buffer size of 4096. pub fn new( @@ -524,7 +524,7 @@ enum ReaderState { unsafe impl Sync for ReaderState {} -impl AsyncRead for WebSocketReader { +impl AsyncRead for WebSocketReader { fn poll_read( self: Pin<&mut Self>, cx: &mut Context,