mirrors/ntex
1
0
Fork 0
mirror of https://github.com/ntex-rs/ntex.git synced 2025-04-03 21:07:39 +03:00
Code Issues Projects Releases Packages Wiki Activity

Add Filter impl to seal

Browse source
This commit is contained in:
James Bell 2025-02-20 15:33:35 +00:00
parent bbbb7a393e
commit 85cfa7e3e4
1 changed files with 38 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

44
ntex-io/src/seal.rs
View file

@ -11,6 +11,38 @@ 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 +57,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 +71,9 @@ impl ops::Deref for IoBoxed {
&self.0
}
}
impl From<IoBoxed> for Io<Sealed> {
fn from(value: IoBoxed) -> Self {
value.0
}
}