Home
last modified time | relevance | path

Searched defs:rx2 (Results 1 – 10 of 10) sorted by relevance

/external/rust/crates/tokio/tests/
Dsync_broadcast.rs74 let mut rx2 = tx.subscribe(); in send_two_recv() localVariable
110 let mut rx2 = tx.subscribe(); in send_two_recv_bounded() localVariable
166 let mut rx2 = tx.subscribe(); in send_slow_rx() localVariable
216 let mut rx2 = tx.subscribe(); in drop_rx_while_values_remain() localVariable
231 let mut rx2 = tx.subscribe(); in lagging_rx() localVariable
321 let mut rx2 = tx.subscribe(); in dropping_tx_notifies_rx() localVariable
Dsync_watch.rs47 let mut rx2 = rx1.clone(); in multi_rx() localVariable
Dtask_local_set.rs438 let rx2 = RX2.load(SeqCst); in local_tasks_are_polled_after_tick() localVariable
/external/rust/crates/tokio/src/sync/tests/
Dloom_broadcast.rs54 let mut rx2 = tx.subscribe(); in broadcast_two() localVariable
99 let mut rx2 = tx.subscribe(); in broadcast_wrap() localVariable
148 let rx2 = tx.subscribe(); in drop_rx() localVariable
Dloom_watch.rs10 let mut rx2 = rx1.clone(); in smoke() localVariable
Dloom_notify.rs84 let rx2 = notify.clone(); in notify_drop() localVariable
/external/rust/crates/tokio-stream/tests/
Dstream_stream_map.rs89 let rx2 = Box::pin(rx2); in multiple_entries() localVariable
178 let rx2 = Box::pin(rx2); in replace() localVariable
/external/rust/crates/futures/tests/
Dasync_await_macros.rs97 let mut rx2 = rx2.fuse(); in select_streams() localVariable
148 let mut rx2 = rx2.fuse(); in select_can_move_uncompleted_futures() localVariable
/external/llvm-project/clang/test/SemaCXX/
Ddefault-constructor-initializers.cpp45 X2 & rx2; member
/external/clang/test/SemaCXX/
Ddefault-constructor-initializers.cpp19 X2 & rx2; // expected-note {{declared here}} member