Add Filter impl to seal (#506)

* Add Filter impl to seal

* Version bump

* Fmt

---------

Co-authored-by: James Bell <jamesbell@microsoft.com>

ntex-io/CHANGES.md

@@ -1,5 +1,9 @@
 # Changes
 
+## [2.9.4] - 2025-02-20
+
+* Impl Filter for Sealed
+
 ## [2.9.3] - 2025-01-21
 
 * Allow to access io write destination buffer

ntex-io/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "ntex-io"
-version = "2.9.3"
+version = "2.9.4"
 authors = ["ntex contributors <team@ntex.rs>"]
 description = "Utilities for encoding and decoding frames"
 keywords = ["network", "framework", "async", "futures"]

ntex-io/src/seal.rs

@@ -11,6 +11,54 @@ impl fmt::Debug for Sealed {
     }
 }
 
+impl Filter for Sealed {
+    fn query(&self, id: std::any::TypeId) -> Option<Box<dyn std::any::Any>> {
+        self.0.query(id)
+    }
+
+    fn process_read_buf(
+        &self,
+        io: &crate::IoRef,
+        stack: &crate::buf::Stack,
+        idx: usize,
+        nbytes: usize,
+    ) -> std::io::Result<crate::filter::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<()> {
+        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<()>> {
+        self.0.shutdown(io, stack, idx)
+    }
+
+    fn poll_read_ready(
+        &self,
+        cx: &mut std::task::Context<'_>,
+    ) -> std::task::Poll<crate::ReadStatus> {
+        self.0.poll_read_ready(cx)
+    }
+
+    fn poll_write_ready(
+        &self,
+        cx: &mut std::task::Context<'_>,
+    ) -> std::task::Poll<crate::WriteStatus> {
+        self.0.poll_write_ready(cx)
+    }
+}
+
 #[derive(Debug)]
 /// Boxed `Io` object with erased filter type
 pub struct IoBoxed(Io<Sealed>);
@@ -25,12 +73,6 @@ impl IoBoxed {
     }
 }
 
-impl From<Io<Sealed>> for IoBoxed {
-    fn from(io: Io<Sealed>) -> Self {
-        Self(io)
-    }
-}
-
 impl<F: Filter> From<Io<F>> for IoBoxed {
     fn from(io: Io<F>) -> Self {
         Self(io.seal())
@@ -45,3 +87,9 @@ impl ops::Deref for IoBoxed {
         &self.0
     }
 }
+
+impl From<IoBoxed> for Io<Sealed> {
+    fn from(value: IoBoxed) -> Self {
+        value.0
+    }
+}