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

Fmt

Browse source
This commit is contained in:
James Bell 2025-02-20 15:37:08 +00:00
parent a9e6041980
commit d4c5f421c3
1 changed files with 21 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -26,19 +26,35 @@ impl Filter for Sealed {
self.0.process_read_buf(io, stack, idx, nbytes) 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<()> { 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) 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<()>> { fn shutdown(
&self,
io: &crate::IoRef,
stack: &crate::buf::Stack,
idx: usize,
) -> std::io::Result<std::task::Poll<()>> {
self.0.shutdown(io, stack, idx) self.0.shutdown(io, stack, idx)
} }
fn poll_read_ready(&self, cx: &mut std::task::Context<'_>) -> std::task::Poll<crate::ReadStatus> { fn poll_read_ready(
&self,
cx: &mut std::task::Context<'_>,
) -> std::task::Poll<crate::ReadStatus> {
self.0.poll_read_ready(cx) self.0.poll_read_ready(cx)
} }
fn poll_write_ready(&self, cx: &mut std::task::Context<'_>) -> std::task::Poll<crate::WriteStatus> { fn poll_write_ready(
&self,
cx: &mut std::task::Context<'_>,
) -> std::task::Poll<crate::WriteStatus> {
self.0.poll_write_ready(cx) self.0.poll_write_ready(cx)
} }
} }
@ -76,4 +92,4 @@ impl From<IoBoxed> for Io<Sealed> {
fn from(value: IoBoxed) -> Self { fn from(value: IoBoxed) -> Self {
value.0 value.0
} }
} }