| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/ |
| D | README.md | 1 # Module kotlinx-coroutines-rx3
64 <!--- MODULE kotlinx-coroutines-rx3 -->
65 <!--- INDEX kotlinx.coroutines.rx3 -->
67 …tps://kotlinlang.org/api/kotlinx.coroutines/kotlinx-coroutines-rx3/kotlinx.coroutines.rx3/rx-compl…
68 …tps://kotlinlang.org/api/kotlinx.coroutines/kotlinx-coroutines-rx3/kotlinx.coroutines.rx3/rx-maybe…
69 …tps://kotlinlang.org/api/kotlinx.coroutines/kotlinx-coroutines-rx3/kotlinx.coroutines.rx3/rx-singl…
70 …tps://kotlinlang.org/api/kotlinx.coroutines/kotlinx-coroutines-rx3/kotlinx.coroutines.rx3/rx-obser…
71 …tps://kotlinlang.org/api/kotlinx.coroutines/kotlinx-coroutines-rx3/kotlinx.coroutines.rx3/rx-flowa…
72 …tps://kotlinlang.org/api/kotlinx.coroutines/kotlinx-coroutines-rx3/kotlinx.coroutines.rx3/as-flowa…
73 …tps://kotlinlang.org/api/kotlinx.coroutines/kotlinx-coroutines-rx3/kotlinx.coroutines.rx3/as-obser…
[all …]
|
| /external/rust/crates/futures/tests/ |
| D | stream_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 | 17 let (tx3, rx3) = oneshot::channel(); in basic_usage()
21 queue.push(rx3); in basic_usage()
45 let (tx3, rx3) = oneshot::channel(); in resolving_errors()
49 queue.push(rx3); in resolving_errors()
73 let (mut tx3, rx3) = oneshot::channel::<()>(); in dropping_ready_queue()
77 queue.push(rx3); in dropping_ready_queue()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/api/ |
| D | kotlinx-coroutines-rx3.api | 1 public final class kotlinx/coroutines/rx3/RxAwaitKt {
16 public final class kotlinx/coroutines/rx3/RxChannelKt {
23 public final class kotlinx/coroutines/rx3/RxCompletableKt {
28 public final class kotlinx/coroutines/rx3/RxConvertKt {
45 public final class kotlinx/coroutines/rx3/RxFlowableKt {
50 public final class kotlinx/coroutines/rx3/RxMaybeKt {
55 public final class kotlinx/coroutines/rx3/RxObservableKt {
60 public final class kotlinx/coroutines/rx3/RxSchedulerKt {
62 …utineDispatcher (Lio/reactivex/rxjava3/core/Scheduler;)Lkotlinx/coroutines/rx3/SchedulerCoroutineD…
66 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/kotlinx-coroutines-rx3/src/ |
| D | module-info.java | 2 module kotlinx.coroutines.rx3 {
9 exports kotlinx.coroutines.rx3;
|
| 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 | RxSingle.kt | 5 package kotlinx.coroutines.rx3 in <lambda>()
|
| D | RxMaybe.kt | 5 package kotlinx.coroutines.rx3
|
| D | RxChannel.kt | 5 package kotlinx.coroutines.rx3
|
| /external/rust/crates/crossbeam-channel/tests/ |
| D | mpsc.rs | 915 let (tx3, rx3) = channel::<()>(); in try_recv_states()
927 rx3.recv().unwrap(); in try_recv_states()
931 rx3.recv().unwrap(); in try_recv_states()
1565 let (tx3, rx3) = sync_channel::<()>(1); in try_recv_states()
1577 rx3.recv().unwrap(); in try_recv_states()
1581 rx3.recv().unwrap(); in try_recv_states()
1741 let (_tx3, rx3) = channel::<i32>(); in smoke2()
1748 _foo = rx3.recv() => panic!("3"), in smoke2()
1770 let (tx3, rx3) = channel::<i32>(); in unblocks()
1777 rx3.recv().unwrap(); in unblocks()
[all …]
|
| /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/tokio/tests/ |
| D | macros_try_join.rs | 68 let (_tx3, rx3) = oneshot::channel::<u32>(); in err_abort_early()
72 rx3.await in err_abort_early()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/ |
| D | BackpressureTest.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 | ObservableCollectTest.kt | 5 package kotlinx.coroutines.rx3 in <lambda>()
|
| D | ObservableSubscriptionSelectTest.kt | 5 package kotlinx.coroutines.rx3 in <lambda>()
|
| D | FlowAsFlowableTest.kt | 5 package kotlinx.coroutines.rx3 in <lambda>()
|
| D | Check.kt | 5 package kotlinx.coroutines.rx3
|
| D | SchedulerStressTest.kt | 5 package kotlinx.coroutines.rx3
|