Searched refs:first_message (Results 1 – 4 of 4) sorted by relevance
8 let first_message = b"Hello, world!"; in test_tcp_sample_application() localVariable25 client_output.blocking_write_util(first_message).unwrap(); in test_tcp_sample_application()34 let data = input.blocking_read(first_message.len() as u64).unwrap(); in test_tcp_sample_application()37 assert_eq!(data, first_message); // Not guaranteed to work but should work in practice. in test_tcp_sample_application()
14 let first_message = b"Hello, world!"; in test_tcp_sample_application() localVariable37 let remaining = data_tx.write_all(first_message.into()).await; in test_tcp_sample_application()47 assert_eq!(result, StreamResult::Complete(first_message.len())); in test_tcp_sample_application()49 assert_eq!(data, first_message); // Not guaranteed to work but should work in practice. in test_tcp_sample_application()
14 let first_message = &[]; in test_udp_sample_application() localVariable29 client.send(first_message.to_vec(), None).await.unwrap(); in test_udp_sample_application()38 assert_eq!(buf, first_message); in test_udp_sample_application()
10 let first_message = &[]; in test_udp_sample_application() localVariable29 data: first_message.to_vec(), in test_udp_sample_application()47 assert_eq!(datagrams[0].data, first_message); in test_udp_sample_application()