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

simplify framed dispatcher states

Browse source
This commit is contained in:
Nikolay Kim 2020-04-13 09:48:46 +06:00
parent f52f7e616c
commit d7699b74d7
3 changed files with 32 additions and 28 deletions
Download patch file Download diff file Expand all files Collapse all files

6
ntex-codec/src/framed.rs
View file

@ -126,13 +126,13 @@ impl<T, U> Framed<T, U> {
#[inline]
/// Get read buffer.
pub fn read_buf_mut(&mut self) -> &mut BytesMut {
pub fn read_buf(&mut self) -> &mut BytesMut {
&mut self.read_buf
}
#[inline]
/// Get write buffer.
pub fn write_buf_mut(&mut self) -> &mut BytesMut {
pub fn write_buf(&mut self) -> &mut BytesMut {
&mut self.write_buf
}
@ -556,6 +556,8 @@ mod tests {
let data = Bytes::from_static(b"GET /test HTTP/1.1\r\n\r\n");
Pin::new(&mut server).start_send(data).unwrap();
assert_eq!(client.read_any(), b"".as_ref());
assert_eq!(server.read_buf(), b"".as_ref());
assert_eq!(server.write_buf(), b"GET /test HTTP/1.1\r\n\r\n".as_ref());
assert!(lazy(|cx| Pin::new(&mut server).poll_flush(cx))
.await