Searched refs:tx3 (Results 1 – 12 of 12) sorted by relevance
| /external/rust/crates/futures/tests/ |
| D | ready_queue.rs | 20 let (tx3, rx3) = oneshot::channel(); in basic_usage()
34 tx3.send("world2").unwrap(); in basic_usage()
54 let (tx3, rx3) = oneshot::channel(); in resolving_errors()
68 tx3.send("world2").unwrap(); in resolving_errors()
88 let (mut tx3, rx3) = oneshot::channel::<()>(); in dropping_ready_queue()
98 assert!(!tx3.poll_canceled(cx).is_ready()); in dropping_ready_queue()
104 assert!(tx3.poll_canceled(cx).is_ready()); in dropping_ready_queue()
|
| D | basic_combinators.rs | 9 let tx3 = tx1.clone(); in basic_future_combinators() localVariable
21 tx3.send(x).unwrap(); // Send 5 in basic_future_combinators()
34 let tx3 = tx1.clone(); in basic_try_future_combinators() localVariable
55 tx3.send(x).unwrap(); // Send 3 in basic_try_future_combinators()
56 tx3.send(4).unwrap(); // Send 4 in basic_try_future_combinators()
|
| D | buffer_unordered.rs | 16 let (tx3, rx3) = std_mpsc::channel(); in works()
21 tx3.send(mytx).unwrap(); in works()
27 tx3.send(mytx).unwrap(); in works()
|
| D | shared.rs | 72 let (tx3, rx3) = oneshot::channel::<u32>(); in drop_on_one_task_ok()
75 let _ = block_on(f2.map_ok(|x| tx3.send(x).unwrap()).map_err(|_| ())); in drop_on_one_task_ok()
|
| D | eventual.rs | 150 let tx3 = tx2.clone(); in select4() localVariable
151 run(future::try_select(p1, p2).map_ok(move |_| tx3.send(()).unwrap())); in select4()
|
| /external/rust/crates/futures-channel/tests/ |
| D | mpsc-close.rs | 30 let (tx2, mut tx3, mut tx4) = (tx1.clone(), tx1.clone(), tx1.clone()); in multiple_senders_disconnect()
36 block_on(tx3.close()).unwrap(); in multiple_senders_disconnect()
39 assert!(tx3.is_closed()); in multiple_senders_disconnect()
52 let (tx2, mut tx3, mut tx4) = (tx1.clone(), tx1.clone(), tx1.clone()); in multiple_senders_disconnect()
58 block_on(tx3.close()).unwrap(); in multiple_senders_disconnect()
61 assert!(tx3.is_closed()); in multiple_senders_disconnect()
|
| /external/rust/crates/crossbeam-channel/tests/ |
| D | mpsc.rs | 902 let (tx3, rx3) = channel::<()>(); in try_recv_states()
906 tx3.send(()).unwrap(); in try_recv_states()
909 tx3.send(()).unwrap(); in try_recv_states()
1534 let (tx3, rx3) = sync_channel::<()>(1); in try_recv_states()
1538 tx3.send(()).unwrap(); in try_recv_states()
1541 tx3.send(()).unwrap(); in try_recv_states()
1739 let (tx3, rx3) = channel::<i32>(); in unblocks()
1756 tx3.send(1).unwrap(); in unblocks()
1768 let (tx3, rx3) = channel::<()>(); in both_ready()
1789 tx3.send(()).unwrap(); in both_ready()
[all …]
|
| /external/rust/crates/tokio/tests/ |
| D | macros_select.rs | 489 let (tx3, rx3) = oneshot::channel::<i32>(); in biased_one_not_ready()
492 tx3.send(3).unwrap(); in biased_one_not_ready()
|
| D | sync_mpsc.rs | 53 let tx3 = tx.clone(); in reserve_disarm() localVariable
61 let mut r3 = task::spawn(tx3.reserve()); in reserve_disarm()
|
| D | rt_common.rs | 763 let (tx3, rx3) = oneshot::channel();
772 tx3.send(()).unwrap();
|
| /external/llvm-project/llvm/test/CodeGen/PowerPC/ |
| D | pr17168.ll | 273 !213 = !DIGlobalVariable(name: "tx3", scope: null, file: !2, line: 31, type: !13, isLocal: true, is…
|
| /external/llvm/test/CodeGen/PowerPC/ |
| D | pr17168.ll | 465 !409 = !DIGlobalVariable(name: "tx3", line: 31, isLocal: true, isDefinition: true, scope: null, fil…
|