Lines Matching refs:recv
46 scope.spawn(|_| r.recv().unwrap()); in len_empty_full()
79 fn recv() { in recv() function
84 assert_eq!(r.recv(), Ok(7)); in recv()
86 assert_eq!(r.recv(), Ok(8)); in recv()
88 assert_eq!(r.recv(), Ok(9)); in recv()
89 assert_eq!(r.recv(), Err(RecvError)); in recv()
136 assert_eq!(r.recv(), Ok(8)); in try_send()
156 assert_eq!(r.recv(), Ok(7)); in send()
157 assert_eq!(r.recv(), Ok(8)); in send()
158 assert_eq!(r.recv(), Ok(9)); in send()
182 assert_eq!(r.recv(), Ok(8)); in send_timeout()
200 assert_eq!(r.recv(), Ok(i)); in len()
240 assert_eq!(r.recv(), Err(RecvError)); in disconnect_wakes_receiver()
259 assert_eq!(r.recv(), Ok(i)); in spsc()
261 assert_eq!(r.recv(), Err(RecvError)); in spsc()
284 let n = r.recv().unwrap(); in mpmc()
312 scope.spawn(|_| r.recv().unwrap()); in stress_oneshot()
410 r.recv().unwrap(); in drops()
441 recv(r1) -> _ => hits[0] += 1, in fairness()
442 recv(r2) -> _ => hits[1] += 1, in fairness()
471 recv(r) -> _ => hits[0] += 1, in fairness_duplicates()
472 recv(r) -> _ => hits[1] += 1, in fairness_duplicates()
473 recv(r) -> _ => hits[2] += 1, in fairness_duplicates()
474 recv(r) -> _ => hits[3] += 1, in fairness_duplicates()
475 recv(r) -> _ => hits[4] += 1, in fairness_duplicates()
503 r.recv() in recv_in_send()
512 send(s, r.recv().unwrap()) -> _ => {} in recv_in_send()
544 .recv() in channel_through_channel()