Lines Matching refs:MSG

9 const MSG: &[u8] = b"hello";  constant
10 const MSG_LEN: usize = MSG.len();
20 sender.send(MSG).await?; in send_recv()
25 assert_eq!(&recv_buf[..len], MSG); in send_recv()
37 poll_fn(|cx| sender.poll_send(cx, MSG)).await?; in send_recv_poll()
43 assert_eq!(read.filled(), MSG); in send_recv_poll()
53 sender.send_to(MSG, &receiver_addr).await?; in send_to_recv_from()
58 assert_eq!(&recv_buf[..len], MSG); in send_to_recv_from()
69 poll_fn(|cx| sender.poll_send_to(cx, MSG, receiver_addr)).await?; in send_to_recv_from_poll()
75 assert_eq!(read.filled(), MSG); in send_to_recv_from_poll()
86 poll_fn(|cx| sender.poll_send_to(cx, MSG, receiver_addr)).await?; in send_to_peek_from()
91 assert_eq!(&recv_buf[..n], MSG); in send_to_peek_from()
97 assert_eq!(&recv_buf[..n], MSG); in send_to_peek_from()
102 assert_eq!(&recv_buf[..n], MSG); in send_to_peek_from()
114 poll_fn(|cx| sender.poll_send_to(cx, MSG, receiver_addr)).await?; in send_to_peek_from_poll()
120 assert_eq!(read.filled(), MSG); in send_to_peek_from_poll()
127 assert_eq!(read.filled(), MSG); in send_to_peek_from_poll()
132 assert_eq!(read.filled(), MSG); in send_to_peek_from_poll()
144 s.send_to(MSG, &addr).await.unwrap(); in split()
148 assert_eq!(&recv_buf[..len], MSG); in split()
177 sender.send_to(MSG, addr).await?; in split_chan()
180 assert_eq!(&recv_buf[..len], MSG); in split_chan()
212 poll_fn(|cx| sender.poll_send_to(cx, MSG, addr)).await?; in split_chan_poll()
217 assert_eq!(read.filled(), MSG); in split_chan_poll()
245 .try_send_to(MSG, receiver.local_addr().unwrap()) in try_send_spawn()
260 let sent = &sender.try_send(MSG).unwrap(); in try_send_spawn()