From ae9d4ab331db1507d51a7786a01508eaf1ee4b15 Mon Sep 17 00:00:00 2001
From: Nikolay Kim <fafhrd91@gmail.com>
Date: Wed, 26 Feb 2025 20:54:21 -0500
Subject: [PATCH] Prepare release (#507)

---
 ntex-io/CHANGES.md   |  4 ++--
 ntex-io/Cargo.toml   |  2 +-
 ntex-io/src/io.rs    |  8 +++++++-
 ntex-io/src/seal.rs  | 43 +++++++++++++++++--------------------------
 ntex-io/src/utils.rs |  2 +-
 5 files changed, 28 insertions(+), 31 deletions(-)

diff --git a/ntex-io/CHANGES.md b/ntex-io/CHANGES.md
index 8fdd0660..508c0ada 100644
--- a/ntex-io/CHANGES.md
+++ b/ntex-io/CHANGES.md
@@ -1,8 +1,8 @@
 # Changes
 
-## [2.9.4] - 2025-02-20
+## [2.10.0] - 2025-02-26
 
-* Impl Filter for Sealed
+* Impl Filter for Sealed #506
 
 ## [2.9.3] - 2025-01-21
 
diff --git a/ntex-io/Cargo.toml b/ntex-io/Cargo.toml
index 63d718f0..d8ab4eed 100644
--- a/ntex-io/Cargo.toml
+++ b/ntex-io/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "ntex-io"
-version = "2.9.4"
+version = "2.10.0"
 authors = ["ntex contributors <team@ntex.rs>"]
 description = "Utilities for encoding and decoding frames"
 keywords = ["network", "framework", "async", "futures"]
diff --git a/ntex-io/src/io.rs b/ntex-io/src/io.rs
index e0b48976..f274bb50 100644
--- a/ntex-io/src/io.rs
+++ b/ntex-io/src/io.rs
@@ -10,7 +10,7 @@ use ntex_util::{future::Either, task::LocalWaker, time::Seconds};
 use crate::buf::Stack;
 use crate::filter::{Base, Filter, Layer, NullFilter};
 use crate::flags::Flags;
-use crate::seal::Sealed;
+use crate::seal::{IoBoxed, Sealed};
 use crate::tasks::{ReadContext, WriteContext};
 use crate::timer::TimerHandle;
 use crate::{Decoded, FilterLayer, Handle, IoStatusUpdate, IoStream, RecvError};
@@ -294,6 +294,12 @@ impl<F: Filter> Io<F> {
         Io(UnsafeCell::new(state), marker::PhantomData)
     }
 
+    #[inline]
+    /// Convert current io stream into boxed version
+    pub fn boxed(self) -> IoBoxed {
+        self.seal().into()
+    }
+
     #[inline]
     /// Map current filter with new one
     pub fn add_filter<U>(self, nf: U) -> Io<Layer<U, F>>
diff --git a/ntex-io/src/seal.rs b/ntex-io/src/seal.rs
index 05f6e395..28dac673 100644
--- a/ntex-io/src/seal.rs
+++ b/ntex-io/src/seal.rs
@@ -1,6 +1,7 @@
-use std::{fmt, ops};
+use std::{any::Any, any::TypeId, fmt, io, ops, task::Context, task::Poll};
 
-use crate::{filter::Filter, Io};
+use crate::filter::{Filter, FilterReadStatus};
+use crate::{buf::Stack, Io, IoRef, ReadStatus, WriteStatus};
 
 /// Sealed filter type
 pub struct Sealed(pub(crate) Box<dyn Filter>);
@@ -12,49 +13,39 @@ impl fmt::Debug for Sealed {
 }
 
 impl Filter for Sealed {
-    fn query(&self, id: std::any::TypeId) -> Option<Box<dyn std::any::Any>> {
+    #[inline]
+    fn query(&self, id: TypeId) -> Option<Box<dyn Any>> {
         self.0.query(id)
     }
 
+    #[inline]
     fn process_read_buf(
         &self,
-        io: &crate::IoRef,
-        stack: &crate::buf::Stack,
+        io: &IoRef,
+        stack: &Stack,
         idx: usize,
         nbytes: usize,
-    ) -> std::io::Result<crate::filter::FilterReadStatus> {
+    ) -> io::Result<FilterReadStatus> {
         self.0.process_read_buf(io, stack, idx, nbytes)
     }
 
-    fn process_write_buf(
-        &self,
-        io: &crate::IoRef,
-        stack: &crate::buf::Stack,
-        idx: usize,
-    ) -> std::io::Result<()> {
+    #[inline]
+    fn process_write_buf(&self, io: &IoRef, stack: &Stack, idx: usize) -> io::Result<()> {
         self.0.process_write_buf(io, stack, idx)
     }
 
-    fn shutdown(
-        &self,
-        io: &crate::IoRef,
-        stack: &crate::buf::Stack,
-        idx: usize,
-    ) -> std::io::Result<std::task::Poll<()>> {
+    #[inline]
+    fn shutdown(&self, io: &IoRef, stack: &Stack, idx: usize) -> io::Result<Poll<()>> {
         self.0.shutdown(io, stack, idx)
     }
 
-    fn poll_read_ready(
-        &self,
-        cx: &mut std::task::Context<'_>,
-    ) -> std::task::Poll<crate::ReadStatus> {
+    #[inline]
+    fn poll_read_ready(&self, cx: &mut Context<'_>) -> Poll<ReadStatus> {
         self.0.poll_read_ready(cx)
     }
 
-    fn poll_write_ready(
-        &self,
-        cx: &mut std::task::Context<'_>,
-    ) -> std::task::Poll<crate::WriteStatus> {
+    #[inline]
+    fn poll_write_ready(&self, cx: &mut Context<'_>) -> Poll<WriteStatus> {
         self.0.poll_write_ready(cx)
     }
 }
diff --git a/ntex-io/src/utils.rs b/ntex-io/src/utils.rs
index c2cd2bbb..d5f0d563 100644
--- a/ntex-io/src/utils.rs
+++ b/ntex-io/src/utils.rs
@@ -27,7 +27,7 @@ where
     S: ServiceFactory<IoBoxed, C>,
     C: Clone,
 {
-    chain_factory(fn_service(|io: Io<F>| Ready::Ok(IoBoxed::from(io))))
+    chain_factory(fn_service(|io: Io<F>| Ready::Ok(io.boxed())))
         .map_init_err(|_| panic!())
         .and_then(srv)
 }