Searched refs:buff (Results 1 – 6 of 6) sorted by relevance
115 let mut buff = vec![0u8; TEST_PIPE_BUFFER_SIZE]; in test_non_fatal_read() localVariable117 let n = e.recv(&mut buff).await?; in test_non_fatal_read()118 assert_eq!(&buff[..n], expected_data); in test_non_fatal_read()120 let n = e.recv(&mut buff).await?; in test_non_fatal_read()121 assert_eq!(&buff[..n], expected_data); in test_non_fatal_read()123 let n = e.recv(&mut buff).await?; in test_non_fatal_read()124 assert_eq!(&buff[..n], expected_data); in test_non_fatal_read()
82 let mut buff = vec![0u8; 1024]; in main() localVariable83 while let Ok(n) = stream2.read(&mut buff).await { in main()84 let ping_msg = String::from_utf8(buff[..n].to_vec()).unwrap(); in main()
98 let mut buff = vec![0u8; 1024]; in main() localVariable99 while let Ok(n) = stream_rx.read(&mut buff).await { in main()100 let pong_msg = String::from_utf8(buff[..n].to_vec()).unwrap(); in main()
79 let mut buff = [0u8; 65535]; in main() localVariable84 while let Ok(n) = stream.read(&mut buff).await { in main()
53 pub buff: Vec<u8>, field75 buff: vec![], in new()93 if ChannelData::is_channel_data(&self.buff) { in handle_request()103 raw: self.buff.clone(), in handle_data_packet()113 raw: self.buff.clone(), in handle_turn_packet()
204 buff: buf[..n].to_vec(), in read_loop()