62     let (tx, mut rx) = broadcast::channel(16);  in send_try_recv_bounded()
64     assert_empty!(rx);  in send_try_recv_bounded()
69     let val = assert_recv!(rx);  in send_try_recv_bounded()
72     assert_empty!(rx);  in send_try_recv_bounded()
98     let (tx, mut rx) = broadcast::channel(16);  in send_recv_bounded()
100     let mut recv = task::spawn(rx.recv());  in send_recv_bounded()
152     let (tx, mut rx) = broadcast::channel(1);  in change_tasks()
154     let mut recv = Box::pin(rx.recv());  in change_tasks()
270     let mut rx = tx.subscribe();  in send_no_rx()  localVariable
274     let val = assert_recv!(rx);  in send_no_rx()
308     let (tx, mut rx) = broadcast::channel(16);  in panic_in_clone()
314         let _ = rx.try_recv();  in panic_in_clone()
319     let val = assert_recv!(rx);  in panic_in_clone()
355     let (tx, rx) = broadcast::channel(16);  in unconsumed_messages_are_dropped()
363     drop(rx);  in unconsumed_messages_are_dropped()
370     let (tx, mut rx) = broadcast::channel(1);  in single_capacity_recvs()
374     assert_eq!(assert_recv!(rx), 1);  in single_capacity_recvs()
375     assert_empty!(rx);  in single_capacity_recvs()
380     let (tx, mut rx) = broadcast::channel(1);  in single_capacity_recvs_after_drop_1()
385     assert_eq!(assert_recv!(rx), 1);  in single_capacity_recvs_after_drop_1()
386     assert_closed!(rx.try_recv());  in single_capacity_recvs_after_drop_1()
391     let (tx, mut rx) = broadcast::channel(1);  in single_capacity_recvs_after_drop_2()
397     assert_lagged!(rx.try_recv(), 1);  in single_capacity_recvs_after_drop_2()
398     assert_eq!(assert_recv!(rx), 2);  in single_capacity_recvs_after_drop_2()
399     assert_closed!(rx.try_recv());  in single_capacity_recvs_after_drop_2()
404     let (tx, mut rx) = broadcast::channel(2);  in dropping_sender_does_not_overwrite()
410     assert_eq!(assert_recv!(rx), 1);  in dropping_sender_does_not_overwrite()
411     assert_eq!(assert_recv!(rx), 2);  in dropping_sender_does_not_overwrite()
412     assert_closed!(rx.try_recv());  in dropping_sender_does_not_overwrite()
417     let (tx, mut rx) = broadcast::channel(2);  in lagging_receiver_recovers_after_wrap_closed_1()
424     assert_lagged!(rx.try_recv(), 1);  in lagging_receiver_recovers_after_wrap_closed_1()
425     assert_eq!(assert_recv!(rx), 2);  in lagging_receiver_recovers_after_wrap_closed_1()
426     assert_eq!(assert_recv!(rx), 3);  in lagging_receiver_recovers_after_wrap_closed_1()
427     assert_closed!(rx.try_recv());  in lagging_receiver_recovers_after_wrap_closed_1()
432     let (tx, mut rx) = broadcast::channel(2);  in lagging_receiver_recovers_after_wrap_closed_2()
440     assert_lagged!(rx.try_recv(), 2);  in lagging_receiver_recovers_after_wrap_closed_2()
441     assert_eq!(assert_recv!(rx), 3);  in lagging_receiver_recovers_after_wrap_closed_2()
442     assert_eq!(assert_recv!(rx), 4);  in lagging_receiver_recovers_after_wrap_closed_2()
443     assert_closed!(rx.try_recv());  in lagging_receiver_recovers_after_wrap_closed_2()
448     let (tx, mut rx) = broadcast::channel(2);  in lagging_receiver_recovers_after_wrap_open()
454     assert_lagged!(rx.try_recv(), 1);  in lagging_receiver_recovers_after_wrap_open()
455     assert_eq!(assert_recv!(rx), 2);  in lagging_receiver_recovers_after_wrap_open()
456     assert_eq!(assert_recv!(rx), 3);  in lagging_receiver_recovers_after_wrap_open()
457     assert_empty!(rx);  in lagging_receiver_recovers_after_wrap_open()
462     let (tx, mut rx) = broadcast::channel(3);  in receiver_len_with_lagged()
469     assert_eq!(rx.len(), 4);  in receiver_len_with_lagged()
470     assert_eq!(assert_recv!(rx), 10);  in receiver_len_with_lagged()
475     assert_eq!(rx.len(), 5);  in receiver_len_with_lagged()
476     assert_lagged!(rx.try_recv(), 1);  in receiver_len_with_lagged()
485     let (tx, mut rx) = broadcast::channel(3);  in resubscribe_points_to_tail()
488     let mut rx_resub = rx.resubscribe();  in resubscribe_points_to_tail()
492     assert_eq!(assert_recv!(rx), 1);  in resubscribe_points_to_tail()
498     assert_eq!(assert_recv!(rx), 2);  in resubscribe_points_to_tail()
499     assert_eq!(assert_recv!(rx), 3);  in resubscribe_points_to_tail()
500     assert_empty!(rx);  in resubscribe_points_to_tail()
508     let (tx, mut rx) = broadcast::channel(1);  in resubscribe_lagged()
512     let mut rx_resub = rx.resubscribe();  in resubscribe_lagged()
513     assert_lagged!(rx.try_recv(), 1);  in resubscribe_lagged()
516     assert_eq!(assert_recv!(rx), 2);  in resubscribe_lagged()
517     assert_empty!(rx);  in resubscribe_lagged()
523     let (tx, rx) = tokio::sync::broadcast::channel::<u32>(2);  in resubscribe_to_closed_channel()
526     let mut rx_resub = rx.resubscribe();  in resubscribe_to_closed_channel()
610     let (tx, mut rx) = broadcast::channel(16);  in send_in_waker_drop()
613         let _ = rx.recv().await;  in send_in_waker_drop()
628     let (tx, mut rx) = broadcast::channel(16);  in send_in_waker_drop()
631         let _ = rx.recv().await;  in send_in_waker_drop()
646     let (tx, mut rx) = broadcast::channel(8);  in receiver_recv_is_cooperative()
653                 assert!(rx.recv().await.is_ok());  in receiver_recv_is_cooperative()