Lines Matching full:codec
3 use tokio_util::codec::{AnyDelimiterCodec, BytesCodec, Decoder, Encoder, LinesCodec};
9 let mut codec = BytesCodec::new(); in bytes_decoder() localVariable
12 assert_eq!("abc", codec.decode(buf).unwrap().unwrap()); in bytes_decoder()
13 assert_eq!(None, codec.decode(buf).unwrap()); in bytes_decoder()
14 assert_eq!(None, codec.decode(buf).unwrap()); in bytes_decoder()
16 assert_eq!("a", codec.decode(buf).unwrap().unwrap()); in bytes_decoder()
21 let mut codec = BytesCodec::new(); in bytes_encoder() localVariable
30 codec in bytes_encoder()
38 codec in bytes_encoder()
41 codec in bytes_encoder()
48 let mut codec = LinesCodec::new(); in lines_decoder() localVariable
52 assert_eq!("line 1", codec.decode(buf).unwrap().unwrap()); in lines_decoder()
53 assert_eq!("line 2", codec.decode(buf).unwrap().unwrap()); in lines_decoder()
54 assert_eq!("line 3", codec.decode(buf).unwrap().unwrap()); in lines_decoder()
55 assert_eq!("", codec.decode(buf).unwrap().unwrap()); in lines_decoder()
56 assert_eq!(None, codec.decode(buf).unwrap()); in lines_decoder()
57 assert_eq!(None, codec.decode_eof(buf).unwrap()); in lines_decoder()
59 assert_eq!(None, codec.decode(buf).unwrap()); in lines_decoder()
60 assert_eq!("\rk", codec.decode_eof(buf).unwrap().unwrap()); in lines_decoder()
61 assert_eq!(None, codec.decode(buf).unwrap()); in lines_decoder()
62 assert_eq!(None, codec.decode_eof(buf).unwrap()); in lines_decoder()
69 let mut codec = LinesCodec::new_with_max_length(MAX_LENGTH); in lines_decoder_max_length() localVariable
75 assert!(codec.decode(buf).is_err()); in lines_decoder_max_length()
77 let line = codec.decode(buf).unwrap().unwrap(); in lines_decoder_max_length()
86 assert!(codec.decode(buf).is_err()); in lines_decoder_max_length()
88 let line = codec.decode(buf).unwrap().unwrap(); in lines_decoder_max_length()
97 let line = codec.decode(buf).unwrap().unwrap(); in lines_decoder_max_length()
106 assert_eq!(None, codec.decode(buf).unwrap()); in lines_decoder_max_length()
107 assert_eq!(None, codec.decode_eof(buf).unwrap()); in lines_decoder_max_length()
109 assert_eq!(None, codec.decode(buf).unwrap()); in lines_decoder_max_length()
111 let line = codec.decode_eof(buf).unwrap().unwrap(); in lines_decoder_max_length()
120 assert_eq!(None, codec.decode(buf).unwrap()); in lines_decoder_max_length()
121 assert_eq!(None, codec.decode_eof(buf).unwrap()); in lines_decoder_max_length()
126 assert!(codec.decode(buf).is_err()); in lines_decoder_max_length()
133 let mut codec = LinesCodec::new_with_max_length(MAX_LENGTH); in lines_decoder_max_length_underrun() localVariable
138 assert_eq!(None, codec.decode(buf).unwrap()); in lines_decoder_max_length_underrun()
140 assert!(codec.decode(buf).is_err()); in lines_decoder_max_length_underrun()
142 assert_eq!(None, codec.decode(buf).unwrap()); in lines_decoder_max_length_underrun()
145 assert_eq!(None, codec.decode(buf).unwrap()); in lines_decoder_max_length_underrun()
147 assert_eq!("line 2", codec.decode(buf).unwrap().unwrap()); in lines_decoder_max_length_underrun()
154 let mut codec = LinesCodec::new_with_max_length(MAX_LENGTH); in lines_decoder_max_length_bursts() localVariable
159 assert_eq!(None, codec.decode(buf).unwrap()); in lines_decoder_max_length_bursts()
161 assert_eq!(None, codec.decode(buf).unwrap()); in lines_decoder_max_length_bursts()
163 assert!(codec.decode(buf).is_err()); in lines_decoder_max_length_bursts()
170 let mut codec = LinesCodec::new_with_max_length(MAX_LENGTH); in lines_decoder_max_length_big_burst() localVariable
175 assert_eq!(None, codec.decode(buf).unwrap()); in lines_decoder_max_length_big_burst()
177 assert!(codec.decode(buf).is_err()); in lines_decoder_max_length_big_burst()
184 let mut codec = LinesCodec::new_with_max_length(MAX_LENGTH); in lines_decoder_max_length_newline_between_decodes() localVariable
189 assert_eq!(None, codec.decode(buf).unwrap()); in lines_decoder_max_length_newline_between_decodes()
192 assert_eq!("hello", codec.decode(buf).unwrap().unwrap()); in lines_decoder_max_length_newline_between_decodes()
200 let mut codec = LinesCodec::new_with_max_length(MAX_LENGTH); in lines_decoder_discard_repeat() localVariable
205 assert!(codec.decode(buf).is_err()); in lines_decoder_discard_repeat()
207 assert_eq!(None, codec.decode(buf).unwrap()); in lines_decoder_discard_repeat()
215 let mut codec = LinesCodec::new_with_max_length(MAX_LENGTH); in lines_decoder_max_length_underrun_twice() localVariable
220 assert_eq!(None, codec.decode(buf).unwrap()); in lines_decoder_max_length_underrun_twice()
222 assert!(codec.decode(buf).is_err()); in lines_decoder_max_length_underrun_twice()
224 assert_eq!(None, codec.decode(buf).unwrap()); in lines_decoder_max_length_underrun_twice()
226 assert_eq!("short", codec.decode(buf).unwrap().unwrap()); in lines_decoder_max_length_underrun_twice()
231 let mut codec = LinesCodec::new(); in lines_encoder() localVariable
234 codec.encode("line 1", &mut buf).unwrap(); in lines_encoder()
237 codec.encode("line 2", &mut buf).unwrap(); in lines_encoder()
243 let mut codec = AnyDelimiterCodec::new(b",;\n\r".to_vec(), b",".to_vec()); in any_delimiters_decoder_any_character() localVariable
247 assert_eq!("chunk 1", codec.decode(buf).unwrap().unwrap()); in any_delimiters_decoder_any_character()
248 assert_eq!("chunk 2", codec.decode(buf).unwrap().unwrap()); in any_delimiters_decoder_any_character()
249 assert_eq!("chunk 3", codec.decode(buf).unwrap().unwrap()); in any_delimiters_decoder_any_character()
250 assert_eq!("", codec.decode(buf).unwrap().unwrap()); in any_delimiters_decoder_any_character()
251 assert_eq!(None, codec.decode(buf).unwrap()); in any_delimiters_decoder_any_character()
252 assert_eq!(None, codec.decode_eof(buf).unwrap()); in any_delimiters_decoder_any_character()
254 assert_eq!(None, codec.decode(buf).unwrap()); in any_delimiters_decoder_any_character()
255 assert_eq!("k", codec.decode_eof(buf).unwrap().unwrap()); in any_delimiters_decoder_any_character()
256 assert_eq!(None, codec.decode(buf).unwrap()); in any_delimiters_decoder_any_character()
257 assert_eq!(None, codec.decode_eof(buf).unwrap()); in any_delimiters_decoder_any_character()
264 let mut codec = in any_delimiters_decoder_max_length() localVariable
271 assert!(codec.decode(buf).is_err()); in any_delimiters_decoder_max_length()
273 let chunk = codec.decode(buf).unwrap().unwrap(); in any_delimiters_decoder_max_length()
282 let chunk = codec.decode(buf).unwrap().unwrap(); in any_delimiters_decoder_max_length()
292 let chunk = codec.decode(buf).unwrap().unwrap(); in any_delimiters_decoder_max_length()
301 let chunk = codec.decode(buf).unwrap().unwrap(); in any_delimiters_decoder_max_length()
310 let chunk = codec.decode(buf).unwrap().unwrap(); in any_delimiters_decoder_max_length()
319 let chunk = codec.decode(buf).unwrap().unwrap(); in any_delimiters_decoder_max_length()
328 assert_eq!(None, codec.decode(buf).unwrap()); in any_delimiters_decoder_max_length()
329 assert_eq!(None, codec.decode_eof(buf).unwrap()); in any_delimiters_decoder_max_length()
331 assert_eq!(None, codec.decode(buf).unwrap()); in any_delimiters_decoder_max_length()
333 let chunk = codec.decode_eof(buf).unwrap().unwrap(); in any_delimiters_decoder_max_length()
342 assert_eq!(None, codec.decode(buf).unwrap()); in any_delimiters_decoder_max_length()
343 assert_eq!(None, codec.decode_eof(buf).unwrap()); in any_delimiters_decoder_max_length()
348 assert!(codec.decode(buf).is_err()); in any_delimiters_decoder_max_length()
355 let mut codec = in any_delimiter_decoder_max_length_underrun() localVariable
361 assert_eq!(None, codec.decode(buf).unwrap()); in any_delimiter_decoder_max_length_underrun()
363 assert!(codec.decode(buf).is_err()); in any_delimiter_decoder_max_length_underrun()
365 assert_eq!(None, codec.decode(buf).unwrap()); in any_delimiter_decoder_max_length_underrun()
368 assert_eq!(None, codec.decode(buf).unwrap()); in any_delimiter_decoder_max_length_underrun()
370 assert_eq!("chunk 2", codec.decode(buf).unwrap().unwrap()); in any_delimiter_decoder_max_length_underrun()
377 let mut codec = in any_delimiter_decoder_max_length_underrun_twice() localVariable
383 assert_eq!(None, codec.decode(buf).unwrap()); in any_delimiter_decoder_max_length_underrun_twice()
385 assert!(codec.decode(buf).is_err()); in any_delimiter_decoder_max_length_underrun_twice()
387 assert_eq!(None, codec.decode(buf).unwrap()); in any_delimiter_decoder_max_length_underrun_twice()
389 assert_eq!("short", codec.decode(buf).unwrap().unwrap()); in any_delimiter_decoder_max_length_underrun_twice()
395 let mut codec = in any_delimiter_decoder_max_length_bursts() localVariable
401 assert_eq!(None, codec.decode(buf).unwrap()); in any_delimiter_decoder_max_length_bursts()
403 assert_eq!(None, codec.decode(buf).unwrap()); in any_delimiter_decoder_max_length_bursts()
405 assert!(codec.decode(buf).is_err()); in any_delimiter_decoder_max_length_bursts()
412 let mut codec = in any_delimiter_decoder_max_length_big_burst() localVariable
418 assert_eq!(None, codec.decode(buf).unwrap()); in any_delimiter_decoder_max_length_big_burst()
420 assert!(codec.decode(buf).is_err()); in any_delimiter_decoder_max_length_big_burst()
427 let mut codec = in any_delimiter_decoder_max_length_delimiter_between_decodes() localVariable
433 assert_eq!(None, codec.decode(buf).unwrap()); in any_delimiter_decoder_max_length_delimiter_between_decodes()
436 assert_eq!("hello", codec.decode(buf).unwrap().unwrap()); in any_delimiter_decoder_max_length_delimiter_between_decodes()
443 let mut codec = in any_delimiter_decoder_discard_repeat() localVariable
449 assert!(codec.decode(buf).is_err()); in any_delimiter_decoder_discard_repeat()
451 assert_eq!(None, codec.decode(buf).unwrap()); in any_delimiter_decoder_discard_repeat()
456 let mut codec = AnyDelimiterCodec::new(b",".to_vec(), b";--;".to_vec()); in any_delimiter_encoder() localVariable
459 codec.encode("chunk 1", &mut buf).unwrap(); in any_delimiter_encoder()
462 codec.encode("chunk 2", &mut buf).unwrap(); in any_delimiter_encoder()