diff --git a/proxmox-http/src/websocket/mod.rs b/proxmox-http/src/websocket/mod.rs index 9aae8df1..a9d21dfc 100644 --- a/proxmox-http/src/websocket/mod.rs +++ b/proxmox-http/src/websocket/mod.rs @@ -273,11 +273,9 @@ impl AsyncWrite for WebSocketWriter { fn poll_write(self: Pin<&mut Self>, cx: &mut Context, buf: &[u8]) -> Poll> { let this = Pin::get_mut(self); - let frametype = OpCode::Binary; - if this.frame.is_none() { // create frame buf - let frame = match create_frame(this.mask, buf, frametype) { + let frame = match create_frame(this.mask, buf, OpCode::Binary) { Ok(f) => f, Err(e) => { return Poll::Ready(Err(io_err_other(e)));