diff --git a/ntex-net/CHANGES.md b/ntex-net/CHANGES.md
index 026e91e6..dc18cb14 100644
--- a/ntex-net/CHANGES.md
+++ b/ntex-net/CHANGES.md
@@ -1,5 +1,9 @@
 # Changes
 
+## [2.5.2] - 2025-03-14
+
+* Fix operation cancelation handling for io-uring driver
+
 ## [2.5.1] - 2025-03-14
 
 * Fix socket connect for io-uring driver
diff --git a/ntex-net/Cargo.toml b/ntex-net/Cargo.toml
index 5cb9f6d8..f2ed2a79 100644
--- a/ntex-net/Cargo.toml
+++ b/ntex-net/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "ntex-net"
-version = "2.5.1"
+version = "2.5.2"
 authors = ["ntex contributors <team@ntex.rs>"]
 description = "ntexwork utils for ntex framework"
 keywords = ["network", "framework", "async", "futures"]
diff --git a/ntex-net/src/rt_uring/driver.rs b/ntex-net/src/rt_uring/driver.rs
index 6cf0b0f2..6a2ba777 100644
--- a/ntex-net/src/rt_uring/driver.rs
+++ b/ntex-net/src/rt_uring/driver.rs
@@ -118,10 +118,16 @@ impl<T> Handler for StreamOpsHandler<T> {
             Operation::Recv { id, buf, context } => {
                 log::debug!("{}: Recv canceled {:?}", context.tag(), id,);
                 context.release_read_buf(buf);
+                if let Some(item) = storage.streams.get_mut(id) {
+                    item.rd_op.take();
+                }
             }
             Operation::Send { id, buf, context } => {
                 log::debug!("{}: Send canceled: {:?}", context.tag(), id);
                 context.release_write_buf(buf);
+                if let Some(item) = storage.streams.get_mut(id) {
+                    item.wr_op.take();
+                }
             }
             Operation::Nop | Operation::Close { .. } => {}
         }
diff --git a/ntex-net/src/rt_uring/io.rs b/ntex-net/src/rt_uring/io.rs
index 2fb23a00..2f111ad7 100644
--- a/ntex-net/src/rt_uring/io.rs
+++ b/ntex-net/src/rt_uring/io.rs
@@ -68,7 +68,6 @@ async fn run<T>(ctl: StreamCtl<T>, context: IoContext) {
 
         let write = match context.poll_write_ready(cx) {
             Poll::Ready(WriteStatus::Ready) => {
-                log::debug!("{}: write ready", context.tag());
                 ctl.resume_write();
                 Poll::Pending
             }