Lines Matching refs:buf
23 let (status, buf) = client.receive_stream.read(Vec::with_capacity(4)).await; in test_tcp_ping_pong()
25 assert_eq!(buf, b"ping"); in test_tcp_ping_pong()
32 let (status, buf) = server.receive_stream.read(Vec::with_capacity(4)).await; in test_tcp_ping_pong()
34 assert_eq!(buf, b"pong"); in test_tcp_ping_pong()
232 let mut buf = Vec::with_capacity(1024); in test_tcp_read_cancellation() localVariable
236 assert!(buf.is_empty()); in test_tcp_read_cancellation()
238 let mut fut = pin!(server.receive_stream.read(buf)); in test_tcp_read_cancellation()
245 buf = b; in test_tcp_read_cancellation()
248 assert_eq!(buf.len(), n); in test_tcp_read_cancellation()
249 for slot in buf.iter_mut() { in test_tcp_read_cancellation()
253 buf.truncate(0); in test_tcp_read_cancellation()