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

Remove unneeded code

Browse source
This commit is contained in:
Nikolay Kim 2023-01-26 16:58:23 +01:00
parent 2853a42d13
commit af018b46fe
1 changed files with 16 additions and 24 deletions
Download patch file Download diff file Expand all files Collapse all files

40
ntex-io/src/ioref.rs
View file

@ -153,6 +153,21 @@ impl IoRef {
}
}
#[inline]
/// Get mut access to write buffer
pub fn with_buf<F, R>(&self, f: F) -> io::Result<R>
where
F: FnOnce(&mut WriteBuf<'_>) -> R,
{
let mut buffer = self.0.buffer.borrow_mut();
let result = buffer.write_buf(self, 0, f);
self.0
.filter
.get()
.process_write_buf(self, &mut buffer, 0)?;
Ok(result)
}
#[inline]
/// Get mut access to write buffer
pub fn with_write_buf<F, R>(&self, f: F) -> io::Result<R>
@ -169,21 +184,6 @@ impl IoRef {
Ok(result)
}
#[inline]
/// Get mut access to write buffer
pub fn with_buf<F, R>(&self, f: F) -> io::Result<R>
where
F: FnOnce(&mut WriteBuf<'_>) -> R,
{
let mut buffer = self.0.buffer.borrow_mut();
let result = buffer.write_buf(self, 0, f);
self.0
.filter
.get()
.process_write_buf(self, &mut buffer, 0)?;
Ok(result)
}
#[inline]
/// Get mut access to read buffer
pub fn with_read_buf<F, R>(&self, f: F) -> R
@ -197,15 +197,7 @@ impl IoRef {
*buf = Some(self.memory_pool().get_read_buf());
}
let result = f(buf.as_mut().unwrap());
// release buffer
if buf.as_ref().map(|b| b.is_empty()).unwrap_or(false) {
if let Some(b) = buf.take() {
self.0.pool.get().release_read_buf(b);
}
}
result
f(buf.as_mut().unwrap())
}
#[inline]