diff --git a/proxmox/src/tools/websocket.rs b/proxmox/src/tools/websocket.rs index 9fc7103c..b4d5f219 100644 --- a/proxmox/src/tools/websocket.rs +++ b/proxmox/src/tools/websocket.rs @@ -291,7 +291,7 @@ pub struct WebSocketReader { state: ReaderState, } -impl WebSocketReader { +impl WebSocketReader { pub fn new(reader: R, callback: CallBack) -> WebSocketReader { Self::with_capacity(reader, callback, 4096) } @@ -307,13 +307,14 @@ impl WebSocketReader { } } - enum ReaderState { NoData, WaitingForData(Pin> + Send + 'static>>), HaveData, } +unsafe impl Sync for ReaderState {} + impl AsyncRead for WebSocketReader { fn poll_read( self: Pin<&mut Self>,