berkus
/
actix-net
mirror of https://github.com/fafhrd91/actix-net
1
0
Fork 0
Code Issues Releases Wiki Activity

add changelog

This commit is contained in:
Rob Ede 2021-10-11 04:14:52 +01:00
parent 3fad5ad108
commit 4965cd403b
No known key found for this signature in database
GPG Key ID: 97C636207D3EF933
3 changed files with 12 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
actix-codec/CHANGES.md
View File

@ -1,6 +1,9 @@
# Changes # Changes
## Unreleased - 2021-xx-xx ## Unreleased - 2021-xx-xx
* Added `LinesCodec.` [#338]
[#338]: https://github.com/actix/actix-net/pull/338
## 0.4.0 - 2021-04-20 ## 0.4.0 - 2021-04-20

2
actix-codec/src/lib.rs
View File

@ -17,8 +17,8 @@ mod framed;
mod lines; mod lines;
pub use self::bcodec::BytesCodec; pub use self::bcodec::BytesCodec;
pub use self::lines::LinesCodec;
pub use self::framed::{Framed, FramedParts}; pub use self::framed::{Framed, FramedParts};
pub use self::lines::LinesCodec;
pub use tokio::io::{AsyncRead, AsyncWrite, ReadBuf}; pub use tokio::io::{AsyncRead, AsyncWrite, ReadBuf};
pub use tokio_util::codec::{Decoder, Encoder}; pub use tokio_util::codec::{Decoder, Encoder};

16
actix-codec/src/lines.rs
View File

@ -35,7 +35,7 @@ impl Decoder for LinesCodec {
return Ok(None); return Ok(None);
} }
let len = match memchr(b'\n', src.chunk()) { let len = match memchr(b'\n', src) {
Some(n) => n, Some(n) => n,
None => { None => {
return Ok(None); return Ok(None);
@ -128,13 +128,13 @@ mod tests {
let mut buf = BytesMut::new(); let mut buf = BytesMut::new();
codec.encode("", &mut buf).unwrap(); codec.encode("", &mut buf).unwrap();
assert_eq!(buf.chunk(), b"\n"); assert_eq!(&buf[..], b"\n");
codec.encode("test", &mut buf).unwrap(); codec.encode("test", &mut buf).unwrap();
assert_eq!(buf.chunk(), b"\ntest\n"); assert_eq!(&buf[..], b"\ntest\n");
codec.encode("a\nb", &mut buf).unwrap(); codec.encode("a\nb", &mut buf).unwrap();
assert_eq!(buf.chunk(), b"\ntest\na\nb\n"); assert_eq!(&buf[..], b"\ntest\na\nb\n");
} }
#[test] #[test]
@ -143,18 +143,18 @@ mod tests {
let mut buf = BytesMut::new(); let mut buf = BytesMut::new();
codec.encode("1234567", &mut buf).unwrap(); codec.encode("1234567", &mut buf).unwrap();
assert_eq!(buf.chunk(), b"1234567\n"); assert_eq!(&buf[..], b"1234567\n");
let mut buf = BytesMut::new(); let mut buf = BytesMut::new();
codec.encode("12345678", &mut buf).unwrap(); codec.encode("12345678", &mut buf).unwrap();
assert_eq!(buf.chunk(), b"12345678\n"); assert_eq!(&buf[..], b"12345678\n");
let mut buf = BytesMut::new(); let mut buf = BytesMut::new();
codec.encode("123456789111213", &mut buf).unwrap(); codec.encode("123456789111213", &mut buf).unwrap();
assert_eq!(buf.chunk(), b"123456789111213\n"); assert_eq!(&buf[..], b"123456789111213\n");
let mut buf = BytesMut::new(); let mut buf = BytesMut::new();
codec.encode("1234567891112131", &mut buf).unwrap(); codec.encode("1234567891112131", &mut buf).unwrap();
assert_eq!(buf.chunk(), b"1234567891112131\n"); assert_eq!(&buf[..], b"1234567891112131\n");
} }
} }