Searched defs:rx2 (Results 1 – 10 of 10) sorted by relevance
74 let mut rx2 = tx.subscribe(); in send_two_recv() localVariable110 let mut rx2 = tx.subscribe(); in send_two_recv_bounded() localVariable166 let mut rx2 = tx.subscribe(); in send_slow_rx() localVariable216 let mut rx2 = tx.subscribe(); in drop_rx_while_values_remain() localVariable231 let mut rx2 = tx.subscribe(); in lagging_rx() localVariable321 let mut rx2 = tx.subscribe(); in dropping_tx_notifies_rx() localVariable
47 let mut rx2 = rx1.clone(); in multi_rx() localVariable
438 let rx2 = RX2.load(SeqCst); in local_tasks_are_polled_after_tick() 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
84 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
97 let mut rx2 = rx2.fuse(); in select_streams() localVariable148 let mut rx2 = rx2.fuse(); in select_can_move_uncompleted_futures() localVariable
45 X2 & rx2; member
19 X2 & rx2; // expected-note {{declared here}} member