(iggy) branch release_script updated: fix compilation

[hgruszecki]

This is an automated email from the ASF dual-hosted git repository.

hgruszecki pushed a commit to branch release_script
in repository https://gitbox.apache.org/repos/asf/iggy.git


The following commit(s) were added to refs/heads/release_script by this push:
     new abedd2200 fix compilation
abedd2200 is described below

commit abedd2200048a7c3ac1a9f30a5df29f974c4703d
Author: Hubert Gruszecki <h.grusze...@gmail.com>
AuthorDate: Mon Dec 1 18:09:37 2025 +0100

    fix compilation
---
 core/server/src/websocket/websocket_listener.rs     | 2 +-
 core/server/src/websocket/websocket_sender.rs       | 4 ++--
 core/server/src/websocket/websocket_tls_listener.rs | 2 +-
 core/server/src/websocket/websocket_tls_sender.rs   | 4 ++--
 4 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/core/server/src/websocket/websocket_listener.rs 
b/core/server/src/websocket/websocket_listener.rs
index b61f783b7..49ad92ccc 100644
--- a/core/server/src/websocket/websocket_listener.rs
+++ b/core/server/src/websocket/websocket_listener.rs
@@ -110,7 +110,7 @@ pub async fn start(
 
 async fn accept_loop(
     listener: TcpListener,
-    ws_config: Option<compio_ws::WebSocketConfig>,
+    ws_config: Option<tungstenite::protocol::WebSocketConfig>,
     shard: Rc<IggyShard>,
     shutdown: ShutdownToken,
 ) -> Result<(), IggyError> {
diff --git a/core/server/src/websocket/websocket_sender.rs 
b/core/server/src/websocket/websocket_sender.rs
index 7759378e0..44ae1e87b 100644
--- a/core/server/src/websocket/websocket_sender.rs
+++ b/core/server/src/websocket/websocket_sender.rs
@@ -22,8 +22,8 @@ use crate::streaming::utils::PooledBuffer;
 use bytes::{BufMut, BytesMut};
 use compio::buf::IoBufMut;
 use compio::net::TcpStream;
-use compio_ws::TungsteniteError;
-use compio_ws::{WebSocketMessage as Message, WebSocketStream};
+use compio_ws::WebSocketStream;
+use compio_ws::tungstenite::{Error as TungsteniteError, Message};
 use iggy_common::IggyError;
 use std::ptr;
 use tracing::{debug, warn};
diff --git a/core/server/src/websocket/websocket_tls_listener.rs 
b/core/server/src/websocket/websocket_tls_listener.rs
index 3aaf02f7b..c50be1ed1 100644
--- a/core/server/src/websocket/websocket_tls_listener.rs
+++ b/core/server/src/websocket/websocket_tls_listener.rs
@@ -159,7 +159,7 @@ pub async fn start(
 async fn accept_loop(
     listener: TcpListener,
     acceptor: TlsAcceptor,
-    ws_config: compio_ws::WebSocketConfig,
+    ws_config: tungstenite::protocol::WebSocketConfig,
     shard: Rc<IggyShard>,
     shutdown: ShutdownToken,
 ) -> Result<(), IggyError> {
diff --git a/core/server/src/websocket/websocket_tls_sender.rs 
b/core/server/src/websocket/websocket_tls_sender.rs
index 06f77161b..7b51e433f 100644
--- a/core/server/src/websocket/websocket_tls_sender.rs
+++ b/core/server/src/websocket/websocket_tls_sender.rs
@@ -23,8 +23,8 @@ use bytes::{BufMut, BytesMut};
 use compio::buf::IoBufMut;
 use compio::net::TcpStream;
 use compio_tls::TlsStream;
-use compio_ws::TungsteniteError;
-use compio_ws::{WebSocketMessage as Message, WebSocketStream};
+use compio_ws::WebSocketStream;
+use compio_ws::tungstenite::{Error as TungsteniteError, Message};
 use iggy_common::IggyError;
 use std::ptr;
 use tracing::debug;