diff --git a/ntex-async-std/Cargo.toml b/ntex-async-std/Cargo.toml
index a6224d48..b4b8b4b8 100644
--- a/ntex-async-std/Cargo.toml
+++ b/ntex-async-std/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "ntex-async-std"
-version = "0.4.0-b.0"
+version = "0.4.0"
 authors = ["ntex contributors <team@ntex.rs>"]
 description = "async-std intergration for ntex framework"
 keywords = ["network", "framework", "async", "futures"]
@@ -17,8 +17,8 @@ path = "src/lib.rs"
 
 [dependencies]
 ntex-bytes = "0.1.21"
-ntex-io = "1.0.0-b.1"
-ntex-util = "1.0.0-b.1"
+ntex-io = "1.0.0"
+ntex-util = "1.0.0"
 log = "0.4"
 pin-project-lite = "0.2"
 async-std = { version = "1", features = ["unstable"] }
diff --git a/ntex-connect/Cargo.toml b/ntex-connect/Cargo.toml
index 944937c4..63528bd2 100644
--- a/ntex-connect/Cargo.toml
+++ b/ntex-connect/Cargo.toml
@@ -37,7 +37,7 @@ async-std = ["ntex-rt/async-std", "ntex-async-std"]
 ntex-service = "2.0.0"
 ntex-io = "1.0.0-b.1"
 ntex-tls = "1.0.0-b.1"
-ntex-util = "1.0.0-b.1"
+ntex-util = "1.0.0"
 ntex-bytes = "0.1.21"
 ntex-http = "0.1"
 ntex-rt = "0.4.7"
diff --git a/ntex-glommio/Cargo.toml b/ntex-glommio/Cargo.toml
index 5acb7e99..36330cdd 100644
--- a/ntex-glommio/Cargo.toml
+++ b/ntex-glommio/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "ntex-glommio"
-version = "0.4.0-b.0"
+version = "0.4.0"
 authors = ["ntex contributors <team@ntex.rs>"]
 description = "glommio intergration for ntex framework"
 keywords = ["network", "framework", "async", "futures"]
@@ -17,8 +17,8 @@ path = "src/lib.rs"
 
 [dependencies]
 ntex-bytes = "0.1.21"
-ntex-io = "1.0.0-b.0"
-ntex-util = "1.0.0-b.0"
+ntex-io = "1.0.0"
+ntex-util = "1.0.0"
 futures-lite = "1.12"
 log = "0.4"
 oneshot = { version = "0.1", default-features = false, features = ["async"] }
diff --git a/ntex-io/Cargo.toml b/ntex-io/Cargo.toml
index abe28fb4..8a5b5451 100644
--- a/ntex-io/Cargo.toml
+++ b/ntex-io/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "ntex-io"
-version = "1.0.0-b.1"
+version = "1.0.0"
 authors = ["ntex contributors <team@ntex.rs>"]
 description = "Utilities for encoding and decoding frames"
 keywords = ["network", "framework", "async", "futures"]
@@ -18,7 +18,7 @@ path = "src/lib.rs"
 [dependencies]
 ntex-codec = "0.6.2"
 ntex-bytes = "0.1.21"
-ntex-util = "1.0.0-b.1"
+ntex-util = "1.0.0"
 ntex-service = "2.0.0"
 
 bitflags = "2.4"
@@ -29,4 +29,4 @@ pin-project-lite = "0.2"
 rand = "0.8"
 env_logger = "0.10"
 
-ntex = { version = "1.0.0-b.0", features = ["tokio"] }
+ntex = { version = "1.0.0-b.1", features = ["tokio"] }
diff --git a/ntex-io/src/tasks.rs b/ntex-io/src/tasks.rs
index 1e185009..fafc8ec8 100644
--- a/ntex-io/src/tasks.rs
+++ b/ntex-io/src/tasks.rs
@@ -13,6 +13,12 @@ impl ReadContext {
         Self(io.clone())
     }
 
+    #[inline]
+    /// Io tag
+    pub fn tag(&self) -> &'static str {
+        self.0.tag()
+    }
+
     #[inline]
     /// Check readiness for read operations
     pub fn poll_ready(&self, cx: &mut Context<'_>) -> Poll<ReadStatus> {
@@ -127,6 +133,12 @@ impl WriteContext {
         Self(io.clone())
     }
 
+    #[inline]
+    /// Io tag
+    pub fn tag(&self) -> &'static str {
+        self.0.tag()
+    }
+
     #[inline]
     /// Return memory pool for this context
     pub fn memory_pool(&self) -> PoolRef {
diff --git a/ntex-service/Cargo.toml b/ntex-service/Cargo.toml
index c14eb27c..e7e12748 100644
--- a/ntex-service/Cargo.toml
+++ b/ntex-service/Cargo.toml
@@ -20,4 +20,4 @@ slab = "0.4"
 
 [dev-dependencies]
 ntex = { version = "1.0.0-b.0", features = ["tokio"] }
-ntex-util = "1.0.0-b.1"
+ntex-util = "1.0.0"
diff --git a/ntex-tls/Cargo.toml b/ntex-tls/Cargo.toml
index d8664855..f2e86a56 100644
--- a/ntex-tls/Cargo.toml
+++ b/ntex-tls/Cargo.toml
@@ -27,7 +27,7 @@ rustls = ["tls_rust"]
 [dependencies]
 ntex-bytes = "0.1.21"
 ntex-io = "1.0.0-b.1"
-ntex-util = "1.0.0-b.1"
+ntex-util = "1.0.0"
 ntex-service = "2.0.0"
 log = "0.4"
 pin-project-lite = "0.2"
diff --git a/ntex-tls/src/lib.rs b/ntex-tls/src/lib.rs
index 13c61e0f..128cea8d 100644
--- a/ntex-tls/src/lib.rs
+++ b/ntex-tls/src/lib.rs
@@ -3,10 +3,6 @@
 
 use std::sync::atomic::{AtomicUsize, Ordering};
 
-#[doc(hidden)]
-#[deprecated]
-pub mod types;
-
 #[cfg(feature = "openssl")]
 pub mod openssl;
 
diff --git a/ntex-tls/src/types.rs b/ntex-tls/src/types.rs
deleted file mode 100644
index fd7bc23d..00000000
--- a/ntex-tls/src/types.rs
+++ /dev/null
@@ -1 +0,0 @@
-pub use ntex_io::types::HttpProtocol;
diff --git a/ntex-tokio/CHANGES.md b/ntex-tokio/CHANGES.md
index 6e4b546c..397bb2b6 100644
--- a/ntex-tokio/CHANGES.md
+++ b/ntex-tokio/CHANGES.md
@@ -1,5 +1,9 @@
 # Changes
 
+## [0.4.0] - 2024-01-09
+
+* Log io tags
+
 ## [0.4.0-b.0] - 2024-01-07
 
 * Use "async fn" in trait for Service definition
diff --git a/ntex-tokio/Cargo.toml b/ntex-tokio/Cargo.toml
index f0b51f48..b4339668 100644
--- a/ntex-tokio/Cargo.toml
+++ b/ntex-tokio/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "ntex-tokio"
-version = "0.4.0-b.0"
+version = "0.4.0"
 authors = ["ntex contributors <team@ntex.rs>"]
 description = "tokio intergration for ntex framework"
 keywords = ["network", "framework", "async", "futures"]
@@ -17,8 +17,8 @@ path = "src/lib.rs"
 
 [dependencies]
 ntex-bytes = "0.1.21"
-ntex-io = "1.0.0-b.1"
-ntex-util = "1.0.0-b.1"
+ntex-io = "1.0.0"
+ntex-util = "1.0.0"
 log = "0.4"
 pin-project-lite = "0.2"
 tokio = { version = "1", default-features = false, features = ["rt", "net", "sync", "signal"] }
diff --git a/ntex-tokio/src/io.rs b/ntex-tokio/src/io.rs
index 8a167a46..76a7ea0f 100644
--- a/ntex-tokio/src/io.rs
+++ b/ntex-tokio/src/io.rs
@@ -69,7 +69,10 @@ impl Future for ReadTask {
                             Poll::Pending => Poll::Pending,
                             Poll::Ready(Ok(n)) => {
                                 if n == 0 {
-                                    log::trace!("tcp stream is disconnected");
+                                    log::trace!(
+                                        "{}: Tcp stream is disconnected",
+                                        this.state.tag()
+                                    );
                                     Poll::Ready(Ok(()))
                                 } else if buf.len() < hw {
                                     continue;
@@ -78,7 +81,11 @@ impl Future for ReadTask {
                                 }
                             }
                             Poll::Ready(Err(err)) => {
-                                log::trace!("read task failed on io {:?}", err);
+                                log::trace!(
+                                    "{}: Read task failed on io {:?}",
+                                    this.state.tag(),
+                                    err
+                                );
                                 Poll::Ready(Err(err))
                             }
                         };
@@ -86,7 +93,7 @@ impl Future for ReadTask {
                 })
             }
             ReadStatus::Terminate => {
-                log::trace!("read task is instructed to shutdown");
+                log::trace!("{}: Read task is instructed to shutdown", this.state.tag());
                 Poll::Ready(())
             }
         }
@@ -148,7 +155,8 @@ impl Future for WriteTask {
                         match ready!(this.state.with_buf(|buf| flush_io(
                             &mut *this.io.borrow_mut(),
                             buf,
-                            cx
+                            cx,
+                            &this.state
                         ))) {
                             Ok(()) => Poll::Pending,
                             Err(e) => {
@@ -158,14 +166,21 @@ impl Future for WriteTask {
                         }
                     }
                     WriteStatus::Timeout(time) => {
-                        log::trace!("initiate timeout delay for {:?}", time);
+                        log::trace!(
+                            "{}: Initiate timeout delay for {:?}",
+                            this.state.tag(),
+                            time
+                        );
                         if delay.is_none() {
                             *delay = Some(sleep(time));
                         }
                         self.poll(cx)
                     }
                     WriteStatus::Shutdown(time) => {
-                        log::trace!("write task is instructed to shutdown");
+                        log::trace!(
+                            "{}: Write task is instructed to shutdown",
+                            this.state.tag()
+                        );
 
                         let timeout = if let Some(delay) = delay.take() {
                             delay
@@ -177,7 +192,10 @@ impl Future for WriteTask {
                         self.poll(cx)
                     }
                     WriteStatus::Terminate => {
-                        log::trace!("write task is instructed to terminate");
+                        log::trace!(
+                            "{}: Write task is instructed to terminate",
+                            this.state.tag()
+                        );
 
                         if !matches!(
                             this.io.borrow().linger(),
@@ -201,14 +219,17 @@ impl Future for WriteTask {
                         Shutdown::None => {
                             // flush write buffer
                             let mut io = this.io.borrow_mut();
-                            match this.state.with_buf(|buf| flush_io(&mut *io, buf, cx)) {
+                            match this
+                                .state
+                                .with_buf(|buf| flush_io(&mut *io, buf, cx, &this.state))
+                            {
                                 Poll::Ready(Ok(())) => {
                                     *st = Shutdown::Flushed;
                                     continue;
                                 }
                                 Poll::Ready(Err(err)) => {
                                     log::trace!(
-                                        "write task is closed with err during flush, {:?}",
+                                        "{}: Write task is closed with err during flush, {:?}", this.state.tag(),
                                         err
                                     );
                                     this.state.close(Some(err));
@@ -226,7 +247,8 @@ impl Future for WriteTask {
                                 }
                                 Poll::Ready(Err(e)) => {
                                     log::trace!(
-                                        "write task is closed with err during shutdown"
+                                        "{}: Write task is closed with err during shutdown",
+                                        this.state.tag()
                                     );
                                     this.state.close(Some(e));
                                     return Poll::Ready(());
@@ -246,13 +268,16 @@ impl Future for WriteTask {
                                         if read_buf.filled().is_empty() =>
                                     {
                                         this.state.close(None);
-                                        log::trace!("tokio write task is stopped");
+                                        log::trace!(
+                                            "{}: Tokio write task is stopped",
+                                            this.state.tag()
+                                        );
                                         return Poll::Ready(());
                                     }
                                     Poll::Pending => {
                                         *count += read_buf.filled().len() as u16;
                                         if *count > 4096 {
-                                            log::trace!("tokio write task is stopped, too much input");
+                                            log::trace!("{}: Tokio write task is stopped, too much input", this.state.tag());
                                             this.state.close(None);
                                             return Poll::Ready(());
                                         }
@@ -268,7 +293,7 @@ impl Future for WriteTask {
                     if delay.poll_elapsed(cx).is_pending() {
                         return Poll::Pending;
                     }
-                    log::trace!("write task is stopped after delay");
+                    log::trace!("{}: Write task is stopped after delay", this.state.tag());
                     this.state.close(None);
                     return Poll::Ready(());
                 }
@@ -282,19 +307,24 @@ pub(super) fn flush_io<T: AsyncRead + AsyncWrite + Unpin>(
     io: &mut T,
     buf: &mut Option<BytesVec>,
     cx: &mut Context<'_>,
+    st: &WriteContext,
 ) -> Poll<io::Result<()>> {
     if let Some(buf) = buf {
         let len = buf.len();
 
         if len != 0 {
-            // log::trace!("flushing framed transport: {:?}", buf.len());
+            // log::trace!("{}: Flushing framed transport: {:?}", st.tag(), buf.len());
 
             let mut written = 0;
             let result = loop {
                 break match Pin::new(&mut *io).poll_write(cx, &buf[written..]) {
                     Poll::Ready(Ok(n)) => {
                         if n == 0 {
-                            log::trace!("Disconnected during flush, written {}", written);
+                            log::trace!(
+                                "{}: Disconnected during flush, written {}",
+                                st.tag(),
+                                written
+                            );
                             Poll::Ready(Err(io::Error::new(
                                 io::ErrorKind::WriteZero,
                                 "failed to write frame to transport",
@@ -315,12 +345,12 @@ pub(super) fn flush_io<T: AsyncRead + AsyncWrite + Unpin>(
                         Poll::Pending
                     }
                     Poll::Ready(Err(e)) => {
-                        log::trace!("Error during flush: {}", e);
+                        log::trace!("{}: Error during flush: {}", st.tag(), e);
                         Poll::Ready(Err(e))
                     }
                 };
             };
-            // log::trace!("flushed {} bytes", written);
+            // log::trace!("{}: flushed {} bytes", st.tag(), written);
 
             // flush
             return if written > 0 {
@@ -328,7 +358,7 @@ pub(super) fn flush_io<T: AsyncRead + AsyncWrite + Unpin>(
                     Poll::Ready(Ok(_)) => result,
                     Poll::Pending => Poll::Pending,
                     Poll::Ready(Err(e)) => {
-                        log::trace!("error during flush: {}", e);
+                        log::trace!("{}: Error during flush: {}", st.tag(), e);
                         Poll::Ready(Err(e))
                     }
                 }
@@ -476,7 +506,10 @@ mod unixstream {
                                 Poll::Pending => Poll::Pending,
                                 Poll::Ready(Ok(n)) => {
                                     if n == 0 {
-                                        log::trace!("tokio unix stream is disconnected");
+                                        log::trace!(
+                                            "{}: Tokio unix stream is disconnected",
+                                            this.state.tag()
+                                        );
                                         Poll::Ready(Ok(()))
                                     } else if buf.len() < hw {
                                         continue;
@@ -485,14 +518,21 @@ mod unixstream {
                                     }
                                 }
                                 Poll::Ready(Err(err)) => {
-                                    log::trace!("unix stream read task failed {:?}", err);
+                                    log::trace!(
+                                        "{}: Unix stream read task failed {:?}",
+                                        this.state.tag(),
+                                        err
+                                    );
                                     Poll::Ready(Err(err))
                                 }
                             };
                         }
                     }
                     ReadStatus::Terminate => {
-                        log::trace!("read task is instructed to shutdown");
+                        log::trace!(
+                            "{}: Read task is instructed to shutdown",
+                            this.state.tag()
+                        );
                         Poll::Ready(Ok(()))
                     }
                 }
@@ -542,7 +582,8 @@ mod unixstream {
                             match ready!(this.state.with_buf(|buf| flush_io(
                                 &mut *this.io.borrow_mut(),
                                 buf,
-                                cx
+                                cx,
+                                &this.state
                             ))) {
                                 Ok(()) => Poll::Pending,
                                 Err(e) => {
@@ -558,7 +599,10 @@ mod unixstream {
                             self.poll(cx)
                         }
                         Poll::Ready(WriteStatus::Shutdown(time)) => {
-                            log::trace!("write task is instructed to shutdown");
+                            log::trace!(
+                                "{}: Write task is instructed to shutdown",
+                                this.state.tag()
+                            );
 
                             let timeout = if let Some(delay) = delay.take() {
                                 delay
@@ -570,7 +614,10 @@ mod unixstream {
                             self.poll(cx)
                         }
                         Poll::Ready(WriteStatus::Terminate) => {
-                            log::trace!("write task is instructed to terminate");
+                            log::trace!(
+                                "{}: Write task is instructed to terminate",
+                                this.state.tag()
+                            );
 
                             let _ = Pin::new(&mut *this.io.borrow_mut()).poll_shutdown(cx);
                             this.state.close(None);
@@ -587,15 +634,16 @@ mod unixstream {
                             Shutdown::None => {
                                 // flush write buffer
                                 let mut io = this.io.borrow_mut();
-                                match this.state.with_buf(|buf| flush_io(&mut *io, buf, cx))
-                                {
+                                match this.state.with_buf(|buf| {
+                                    flush_io(&mut *io, buf, cx, &this.state)
+                                }) {
                                     Poll::Ready(Ok(())) => {
                                         *st = Shutdown::Flushed;
                                         continue;
                                     }
                                     Poll::Ready(Err(err)) => {
                                         log::trace!(
-                                            "write task is closed with err during flush, {:?}",
+                                            "{}: Write task is closed with err during flush, {:?}", this.state.tag(),
                                             err
                                         );
                                         this.state.close(Some(err));
@@ -614,7 +662,7 @@ mod unixstream {
                                     }
                                     Poll::Ready(Err(e)) => {
                                         log::trace!(
-                                            "write task is closed with err during shutdown"
+                                            "{}: Write task is closed with err during shutdown", this.state.tag()
                                         );
                                         this.state.close(Some(e));
                                         return Poll::Ready(());
@@ -634,14 +682,17 @@ mod unixstream {
                                             if read_buf.filled().is_empty() =>
                                         {
                                             this.state.close(None);
-                                            log::trace!("write task is stopped");
+                                            log::trace!(
+                                                "{}: Write task is stopped",
+                                                this.state.tag()
+                                            );
                                             return Poll::Ready(());
                                         }
                                         Poll::Pending => {
                                             *count += read_buf.filled().len() as u16;
                                             if *count > 4096 {
                                                 log::trace!(
-                                                    "write task is stopped, too much input"
+                                                    "{}: Write task is stopped, too much input", this.state.tag()
                                                 );
                                                 this.state.close(None);
                                                 return Poll::Ready(());
@@ -658,7 +709,10 @@ mod unixstream {
                         if delay.poll_elapsed(cx).is_pending() {
                             return Poll::Pending;
                         }
-                        log::trace!("write task is stopped after delay");
+                        log::trace!(
+                            "{}: Write task is stopped after delay",
+                            this.state.tag()
+                        );
                         this.state.close(None);
                         return Poll::Ready(());
                     }
diff --git a/ntex/Cargo.toml b/ntex/Cargo.toml
index 366a3efb..b01d31af 100644
--- a/ntex/Cargo.toml
+++ b/ntex/Cargo.toml
@@ -54,15 +54,15 @@ ntex-http = "0.1.11"
 ntex-router = "0.5.2"
 ntex-service = "2.0.0"
 ntex-macros = "0.1.3"
-ntex-util = "1.0.0-b.0"
+ntex-util = "1.0.0"
 ntex-bytes = "0.1.21"
 ntex-h2 = "0.5.0-b.0"
 ntex-rt = "0.4.11"
-ntex-io = "1.0.0-b.1"
+ntex-io = "1.0.0"
 ntex-tls = "1.0.0-b.1"
-ntex-tokio = { version = "0.4.0-b.0", optional = true }
-ntex-glommio = { version = "0.4.0-b.0", optional = true }
-ntex-async-std = { version = "0.4.0-b.0", optional = true }
+ntex-tokio = { version = "0.4.0", optional = true }
+ntex-glommio = { version = "0.4.0", optional = true }
+ntex-async-std = { version = "0.4.0", optional = true }
 
 async-channel = "2.1"
 base64 = "0.21"