Prepare release

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
 

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"]

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>>

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)
     }
 }

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)
 }