Lines Matching refs:out_queue
1097 out_queue: VecDeque<Vec<u8>>, field
1102 Self { in_queue: VecDeque::new(), out_queue: VecDeque::new() } in new()
1124 self.out_queue.push_back(packet.into()); in send_packet()
1132 out_queue: VecDeque<u8>, field
1157 data.iter().for_each(|v| self.out_queue.push_back(*v)); in write_exact()
1170 assert_eq!(transport.out_queue, [b"FAILCommand not found"]); in test_non_exist_command()
1181 assert_eq!(transport.out_queue, [b"FAILInvalid Command"]); in test_non_ascii_command_string()
1192 assert_eq!(transport.out_queue, [b"OKAY0x400"]); in test_get_var_max_download_size()
1219 transport.out_queue, in test_get_var()
1249 transport.out_queue, in test_get_var_all()
1276 transport.out_queue, in test_download()
1290 assert_eq!(transport.out_queue, [b"FAILNot enough argument"]); in test_download_not_enough_args()
1301 assert_eq!(transport.out_queue.len(), 1); in test_download_invalid_hex_string()
1302 assert!(transport.out_queue[0].starts_with(b"FAIL")); in test_download_invalid_hex_string()
1312 assert_eq!(transport.out_queue, VecDeque::<Vec<u8>>::from([msg.as_bytes().into()])); in test_download_size()
1338 transport.out_queue, in test_download_more_than_expected()
1370 transport.out_queue, in test_oem_cmd()
1401 transport.out_queue, in test_flash()
1415 assert_eq!(transport.out_queue, [b"FAILMissing partition"]); in test_flash_missing_partition()
1445 transport.out_queue, in test_upload()
1514 transport.out_queue, in test_fetch()
1541 assert!(transport.out_queue.iter().all(|v| v.starts_with(b"FAIL"))); in test_fetch_invalid_args()
1566 assert_eq!(tcp_stream.out_queue, VecDeque::from(expected.concat())); in test_fastboot_tcp()