| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/ |
| D | README.md | 1 # Module kotlinx-coroutines-rx3
58 <!--- MODULE kotlinx-coroutines-rx3 -->
59 <!--- INDEX kotlinx.coroutines.rx3 -->
60 …https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-rx3/kotlinx.coroutines.rx3/rx-compl…
61 …https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-rx3/kotlinx.coroutines.rx3/rx-maybe…
62 …https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-rx3/kotlinx.coroutines.rx3/rx-singl…
63 …https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-rx3/kotlinx.coroutines.rx3/rx-obser…
64 …https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-rx3/kotlinx.coroutines.rx3/rx-flowa…
65 …https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-rx3/kotlinx.coroutines.rx3/kotlinx.…
66 …https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-rx3/kotlinx.coroutines.rx3/kotlinx.…
[all …]
|
| /external/rust/crates/futures/tests/ |
| D | buffer_unordered.rs | 16 let (tx3, rx3) = std_mpsc::channel(); in works()
38 let o1 = rx3.recv().unwrap(); in works()
39 let o2 = rx3.recv().unwrap(); in works()
40 let o3 = rx3.recv().unwrap(); in works()
41 let o4 = rx3.recv().unwrap(); in works()
54 let o5 = rx3.recv().unwrap(); in works()
55 let o6 = rx3.recv().unwrap(); in works()
56 let o7 = rx3.recv().unwrap(); in works()
57 let o8 = rx3.recv().unwrap(); in works()
58 let o9 = rx3.recv().unwrap(); in works()
|
| D | ready_queue.rs | 20 let (tx3, rx3) = oneshot::channel(); in basic_usage()
24 queue.push(rx3); in basic_usage()
54 let (tx3, rx3) = oneshot::channel(); in resolving_errors()
58 queue.push(rx3); in resolving_errors()
88 let (mut tx3, rx3) = oneshot::channel::<()>(); in dropping_ready_queue()
92 queue.push(rx3); in dropping_ready_queue()
|
| D | shared.rs | 72 let (tx3, rx3) = oneshot::channel::<u32>(); in drop_on_one_task_ok()
82 let result = block_on(rx3).unwrap(); in drop_on_one_task_ok()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/api/ |
| D | kotlinx-coroutines-rx3.api | 1 public final class kotlinx/coroutines/rx3/RxAwaitKt {
14 public final class kotlinx/coroutines/rx3/RxChannelKt {
21 public final class kotlinx/coroutines/rx3/RxCompletableKt {
26 public final class kotlinx/coroutines/rx3/RxConvertKt {
43 public final class kotlinx/coroutines/rx3/RxFlowableKt {
48 public final class kotlinx/coroutines/rx3/RxMaybeKt {
53 public final class kotlinx/coroutines/rx3/RxObservableKt {
58 public final class kotlinx/coroutines/rx3/RxSchedulerKt {
59 …utineDispatcher (Lio/reactivex/rxjava3/core/Scheduler;)Lkotlinx/coroutines/rx3/SchedulerCoroutineD…
62 public final class kotlinx/coroutines/rx3/RxSingleKt {
[all …]
|
| /external/rust/crates/tokio/src/sync/tests/ |
| D | loom_watch.rs | 11 let mut rx3 = rx1.clone(); in smoke() localVariable
25 block_on(rx3.changed()).unwrap(); in smoke()
26 assert_eq!(*rx3.borrow(), 2); in smoke()
|
| /external/kotlinx.coroutines/reactive/ |
| D | README.md | 11 * [kotlinx-coroutines-rx3](kotlinx-coroutines-rx3/README.md) -- utilities for [RxJava 3.x](https://…
|
| /external/rust/crates/crossbeam-channel/tests/ |
| D | mpsc.rs | 902 let (tx3, rx3) = channel::<()>(); in try_recv_states()
914 rx3.recv().unwrap(); in try_recv_states()
918 rx3.recv().unwrap(); in try_recv_states()
1534 let (tx3, rx3) = sync_channel::<()>(1); in try_recv_states()
1546 rx3.recv().unwrap(); in try_recv_states()
1550 rx3.recv().unwrap(); in try_recv_states()
1710 let (_tx3, rx3) = channel::<i32>(); in smoke2()
1717 _foo = rx3.recv() => panic!("3"), in smoke2()
1739 let (tx3, rx3) = channel::<i32>(); in unblocks()
1746 rx3.recv().unwrap(); in unblocks()
[all …]
|
| /external/rust/crates/tokio/tests/ |
| D | macros_try_join.rs | 58 let (_tx3, rx3) = oneshot::channel::<u32>(); in err_abort_early()
62 rx3.await in err_abort_early()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/ |
| D | RxCancellable.kt | 5 package kotlinx.coroutines.rx3
|
| D | RxFlowable.kt | 5 package kotlinx.coroutines.rx3
|
| D | RxCompletable.kt | 5 package kotlinx.coroutines.rx3 in <lambda>()
|
| D | RxScheduler.kt | 5 package kotlinx.coroutines.rx3
|
| D | RxMaybe.kt | 5 package kotlinx.coroutines.rx3 in <lambda>()
|
| D | RxSingle.kt | 5 package kotlinx.coroutines.rx3 in <lambda>()
|
| D | RxChannel.kt | 5 package kotlinx.coroutines.rx3
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/ |
| D | BackpressureTest.kt | 5 package kotlinx.coroutines.rx3
|
| D | SchedulerTest.kt | 5 package kotlinx.coroutines.rx3
|
| D | IterableFlowAsFlowableTckTest.kt | 5 package kotlinx.coroutines.rx3
|
| D | ObservableSourceAsFlowStressTest.kt | 5 package kotlinx.coroutines.rx3
|
| D | ObservableCompletionStressTest.kt | 5 package kotlinx.coroutines.rx3 in <lambda>()
|
| D | FlowableContextTest.kt | 5 package kotlinx.coroutines.rx3
|
| D | ObservableSubscriptionSelectTest.kt | 5 package kotlinx.coroutines.rx3
|
| D | Check.kt | 5 package kotlinx.coroutines.rx3
|
| D | FlowAsFlowableTest.kt | 5 package kotlinx.coroutines.rx3 in <lambda>()
|