Searched defs:rx2 (Results 1 – 9 of 9) sorted by relevance
77 let mut rx2 = tx.subscribe(); in send_two_recv() localVariable113 let mut rx2 = tx.subscribe(); in send_two_recv_bounded() localVariable169 let mut rx2 = tx.subscribe(); in send_slow_rx() localVariable219 let mut rx2 = tx.subscribe(); in drop_rx_while_values_remain() localVariable234 let mut rx2 = tx.subscribe(); in lagging_rx() localVariable327 let mut rx2 = tx.subscribe(); in dropping_tx_notifies_rx() localVariable534 let mut rx2 = tx.subscribe(); in sender_len() localVariable571 let mut rx2 = tx.subscribe(); in sender_len_random() localVariable
50 let mut rx2 = rx1.clone(); in multi_rx() localVariable224 let mut rx2 = rx.clone(); in send_modify_panic() localVariable
506 let rx2 = RX2.load(SeqCst); in local_tasks_are_polled_after_tick_inner() localVariable
54 let mut rx2 = tx.subscribe(); in broadcast_two() localVariable99 let mut rx2 = tx.subscribe(); in broadcast_wrap() localVariable148 let rx2 = tx.subscribe(); in drop_rx() localVariable
10 let mut rx2 = rx1.clone(); in smoke() localVariable
113 let rx2 = notify.clone(); in notify_drop() localVariable
89 let rx2 = Box::pin(rx2); in multiple_entries() localVariable178 let rx2 = Box::pin(rx2); in replace() localVariable
83 let mut rx2 = rx2.fuse(); in select_streams() localVariable129 let mut rx2 = rx2.fuse(); in select_can_move_uncompleted_futures() localVariable
19 X2 & rx2; // expected-note {{declared here}} member