tokio-rs/tokio
1
0
Fork 0
mirror of https://github.com/tokio-rs/tokio.git synced 2026-09-08 00:00:13 +02:00
Code Issues Packages Projects Releases Wiki Activity

Update lines_encoder test to use LinesCodec (#544)

Browse Source 
The `lines_encoder` test is a copy/paste of `bytes_encoder` and not
testing the LinesCodec encoding at all. This updates the test to do
simple validations of the LinesCodec encoding.
This commit is contained in:
Gary M. Josack
2018-08-15 07:51:42 -04:00
committed by Toby Lawrence
parent 2e343f9e42
commit 28010b5962
1 changed files with 5 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tokio-codec/tests/codecs.rs
+5 -13
View File
@@ -57,20 +57,12 @@ fn lines_decoder() {
#[test] #[test]
fn lines_encoder() { fn lines_encoder() {
let mut codec = BytesCodec::new(); let mut codec = LinesCodec::new();
// Default capacity of BytesMut
#[cfg(target_pointer_width = "64")]
const INLINE_CAP: usize = 4 * 8 - 1;
#[cfg(target_pointer_width = "32")]
const INLINE_CAP: usize = 4 * 4 - 1;
let mut buf = BytesMut::new(); let mut buf = BytesMut::new();
codec.encode(Bytes::from_static(&[b'a'; INLINE_CAP + 1]), &mut buf).unwrap();
// Default capacity of Framed Read codec.encode(String::from("line 1"), &mut buf).unwrap();
const INITIAL_CAPACITY: usize = 8 * 1024; assert_eq!("line 1\n", buf);
let mut buf = BytesMut::with_capacity(INITIAL_CAPACITY); codec.encode(String::from("line 2"), &mut buf).unwrap();
codec.encode(Bytes::from_static(&[b'a'; INITIAL_CAPACITY + 1]), &mut buf).unwrap(); assert_eq!("line 1\nline 2\n", buf);
} }