Home
last modified time | relevance | path

Searched refs:rx2 (Results 1 – 25 of 72) sorted by relevance

123

/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/
DREADME.md1 # Module kotlinx-coroutines-rx2
62 <!--- MODULE kotlinx-coroutines-rx2 -->
63 <!--- INDEX kotlinx.coroutines.rx2 -->
64 …https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-rx2/kotlinx.coroutines.rx2/rx-compl…
65 …https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-rx2/kotlinx.coroutines.rx2/rx-maybe…
66 …https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-rx2/kotlinx.coroutines.rx2/rx-singl…
67 …https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-rx2/kotlinx.coroutines.rx2/rx-obser…
68 …https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-rx2/kotlinx.coroutines.rx2/rx-flowa…
69 …https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-rx2/kotlinx.coroutines.rx2/kotlinx.…
70 …https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-rx2/kotlinx.coroutines.rx2/kotlinx.…
[all …]
/external/rust/crates/futures/tests/
Deager_drop.rs10 let (tx2, rx2) = mpsc::channel::<()>(); in map_ok()
20 rx2.recv().unwrap(); in map_ok()
32 let (tx2, rx2) = mpsc::channel::<()>(); in map_err()
42 rx2.recv().unwrap(); in map_err()
75 let (tx2, rx2) = mpsc::channel::<()>(); in then_drops_eagerly()
85 assert_eq!(Err(mpsc::TryRecvError::Empty), rx2.try_recv()); in then_drops_eagerly()
87 rx2.recv().unwrap(); in then_drops_eagerly()
99 let (tx2, rx2) = mpsc::channel::<()>(); in and_then_drops_eagerly()
109 assert_eq!(Err(mpsc::TryRecvError::Empty), rx2.try_recv()); in and_then_drops_eagerly()
111 rx2.recv().unwrap(); in and_then_drops_eagerly()
[all …]
Doneshot.rs10 let (tx2, rx2) = mpsc::channel(); in oneshot_send1()
14 assert_eq!(1, rx2.recv().unwrap()); in oneshot_send1()
27 let (tx2, rx2) = mpsc::channel(); in oneshot_send2()
31 assert_eq!(1, rx2.recv().unwrap()); in oneshot_send2()
43 let (tx2, rx2) = mpsc::channel(); in oneshot_send3()
47 assert_eq!(1, rx2.recv().unwrap()); in oneshot_send3()
58 let (tx2, rx2) = mpsc::channel(); in oneshot_drop_tx1()
63 assert_eq!(Err(oneshot::Canceled), rx2.recv().unwrap()); in oneshot_drop_tx1()
75 let (tx2, rx2) = mpsc::channel(); in oneshot_drop_tx2()
81 assert_eq!(Err(oneshot::Canceled), rx2.recv().unwrap()); in oneshot_drop_tx2()
Dasync_await_macros.rs23 let (tx2, rx2) = oneshot::channel::<i32>(); in join()
26 let res = join!(rx1, rx2); in join()
48 let (_tx2, rx2) = oneshot::channel::<i32>(); in select()
57 _ = rx2.fuse() => unreachable!(), in select()
71 let (_tx2, rx2) = oneshot::channel::<i32>(); in select_biased()
80 _ = rx2.fuse() => unreachable!(), in select_biased()
95 let (mut tx2, rx2) = mpsc::channel::<i32>(1); in select_streams()
97 let mut rx2 = rx2.fuse(); in select_streams() localVariable
105 _ = rx2.next() => panic!(), in select_streams()
119 x = rx2.next() => if let Some(x) = x { total += x; }, in select_streams()
[all …]
Dready_queue.rs19 let (tx2, rx2) = oneshot::channel(); in basic_usage()
23 queue.push(rx2); in basic_usage()
53 let (tx2, rx2) = oneshot::channel(); in resolving_errors()
57 queue.push(rx2); in resolving_errors()
87 let (mut tx2, rx2) = oneshot::channel::<()>(); in dropping_ready_queue()
91 queue.push(rx2); in dropping_ready_queue()
Dsink_fanout.rs10 let (tx2, rx2) = mpsc::channel(2); in it_works()
17 let collect_fut2 = rx2.collect::<Vec<_>>(); in it_works()
Dbuffer_unordered.rs15 let (tx2, rx2) = std_mpsc::channel(); in works()
23 rx2.recv().unwrap(); in works()
/external/rust/crates/tokio/tests/
Dsync_broadcast.rs74 let mut rx2 = tx.subscribe(); in send_two_recv() localVariable
77 assert_empty!(rx2); in send_two_recv()
85 let val = assert_recv!(rx2); in send_two_recv()
89 assert_empty!(rx2); in send_two_recv()
110 let mut rx2 = tx.subscribe(); in send_two_recv_bounded() localVariable
113 let mut recv2 = task::spawn(rx2.recv()); in send_two_recv_bounded()
131 let mut recv2 = task::spawn(rx2.recv()); in send_two_recv_bounded()
166 let mut rx2 = tx.subscribe(); in send_slow_rx() localVariable
169 let mut recv2 = task::spawn(rx2.recv()); in send_slow_rx()
206 let val = assert_recv!(rx2); in send_slow_rx()
[all …]
Dsync_watch.rs47 let mut rx2 = rx1.clone(); in multi_rx() localVariable
51 let mut t2 = spawn(rx2.changed()); in multi_rx()
57 assert_eq!(*rx2.borrow(), "one"); in multi_rx()
59 let mut t2 = spawn(rx2.changed()); in multi_rx()
93 assert_eq!(*rx2.borrow(), "three"); in multi_rx()
97 let mut t2 = spawn(rx2.changed()); in multi_rx()
108 assert_eq!(*rx2.borrow(), "four"); in multi_rx()
Dmacros_select.rs106 let (_tx2, rx2) = oneshot::channel::<i32>(); in one_ready()
114 _ = rx2 => unreachable!(), in one_ready()
123 let (tx2, mut rx2) = mpsc::unbounded_channel::<i32>(); in select_streams()
146 Some(y) = rx2.recv() => { in select_streams()
162 let (tx2, mut rx2) = oneshot::channel::<i32>(); in move_uncompleted_futures()
172 assert_eq!(2, assert_ok!(rx2.await)); in move_uncompleted_futures()
175 res = &mut rx2 => { in move_uncompleted_futures()
328 let (tx2, mut rx2) = oneshot::channel(); in join_with_select()
337 v2 = &mut rx2, if b.is_none() => b = Some(assert_ok!(v2)) in join_with_select()
488 let (tx2, rx2) = oneshot::channel::<i32>(); in biased_one_not_ready()
[all …]
Dmacros_try_join.rs36 let (tx2, rx2) = oneshot::channel::<u32>(); in two_await()
39 task::spawn(async { tokio::try_join!(async { rx1.await }, async { rx2.await }) }); in two_await()
57 let (tx2, rx2) = oneshot::channel::<u32>(); in err_abort_early()
61 tokio::try_join!(async { rx1.await }, async { rx2.await }, async { in err_abort_early()
Drt_common.rs150 let (tx2, rx2) = oneshot::channel();
161 assert_ok!(rx2.await)
361 let (tx2, rx2) = oneshot::channel();
380 assert_ok!(rx2.await);
566 let (tx2, rx2) = oneshot::channel();
570 rx2.await.unwrap();
762 let (tx2, rx2) = oneshot::channel();
789 let _ = rx2.await;
1067 let (tx2, mut rx2) = mpsc::unbounded_channel();
1076 rx2.recv().await.unwrap();
[all …]
Dmacros_join.rs36 let (tx2, rx2) = oneshot::channel::<u32>(); in two_await()
39 tokio::join!(async { rx1.await.unwrap() }, async { rx2.await.unwrap() }) in two_await()
Dtask_local_set.rs438 let rx2 = RX2.load(SeqCst); in local_tasks_are_polled_after_tick() localVariable
439 println!("EXPECT = {}; RX1 = {}; RX2 = {}", EXPECTED, rx1, rx2); in local_tasks_are_polled_after_tick()
441 assert_eq!(EXPECTED, rx2); in local_tasks_are_polled_after_tick()
463 let (tx2, rx2) = oneshot::channel(); in acquire_mutex_in_drop()
467 let _ = rx2.await; in acquire_mutex_in_drop()
/external/rust/crates/tokio/src/sync/tests/
Dloom_broadcast.rs54 let mut rx2 = tx.subscribe(); in broadcast_two() localVariable
73 let v = assert_ok!(rx2.recv().await); in broadcast_two()
76 let v = assert_ok!(rx2.recv().await); in broadcast_two()
79 match assert_err!(rx2.recv().await) { in broadcast_two()
99 let mut rx2 = tx.subscribe(); in broadcast_wrap() localVariable
122 match rx2.recv().await { in broadcast_wrap()
148 let rx2 = tx.subscribe(); in drop_rx() localVariable
169 drop(rx2); in drop_rx()
Dloom_watch.rs10 let mut rx2 = rx1.clone(); in smoke() localVariable
22 block_on(rx2.changed()).unwrap(); in smoke()
23 assert_eq!(*rx2.borrow(), 2); in smoke()
Dloom_notify.rs84 let rx2 = notify.clone(); in notify_drop() localVariable
99 rx2.notified().await; in notify_drop()
101 rx2.notify_one(); in notify_drop()
102 rx2.notified().await; in notify_drop()
/external/rust/crates/crossbeam-channel/tests/
Dmpsc.rs365 let (tx2, rx2) = channel::<i32>(); in send_from_outside_runtime()
369 assert_eq!(rx2.recv().unwrap(), 1); in send_from_outside_runtime()
399 let (tx2, rx2) = channel::<i32>(); in no_runtime()
406 assert_eq!(rx2.recv().unwrap(), 2); in no_runtime()
901 let (tx2, rx2) = channel::<()>(); in try_recv_states()
904 rx2.recv().unwrap(); in try_recv_states()
907 rx2.recv().unwrap(); in try_recv_states()
928 let (tx2, rx2) = channel(); in destroy_upgraded_shared_port_when_sender_still_active()
945 rx2.recv().unwrap(); in destroy_upgraded_shared_port_when_sender_still_active()
1533 let (tx2, rx2) = sync_channel::<()>(1); in try_recv_states()
[all …]
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/api/
Dkotlinx-coroutines-rx2.api1 public final class kotlinx/coroutines/rx2/RxAwaitKt {
14 public final class kotlinx/coroutines/rx2/RxChannelKt {
23 public final class kotlinx/coroutines/rx2/RxCompletableKt {
30 public final class kotlinx/coroutines/rx2/RxConvertKt {
48 public final class kotlinx/coroutines/rx2/RxFlowableKt {
55 public final class kotlinx/coroutines/rx2/RxMaybeKt {
62 public final class kotlinx/coroutines/rx2/RxObservableKt {
69 public final class kotlinx/coroutines/rx2/RxSchedulerKt {
70 …public static final fun asCoroutineDispatcher (Lio/reactivex/Scheduler;)Lkotlinx/coroutines/rx2/Sc…
73 public final class kotlinx/coroutines/rx2/RxSingleKt {
[all …]
/external/rust/crates/futures-channel/tests/
Doneshot.rs48 let (tx2, rx2) = mpsc::channel(); in cancel_lots()
51 rx2.recv().unwrap(); in cancel_lots()
84 let (tx2, rx2) = mpsc::channel(); in close_wakes()
87 rx2.recv().unwrap(); in close_wakes()
/external/rust/crates/tokio-stream/tests/
Dstream_stream_map.rs86 let (tx2, rx2) = mpsc::unbounded_channel_stream(); in multiple_entries()
89 let rx2 = Box::pin(rx2); in multiple_entries() localVariable
92 map.insert("bar", rx2); in multiple_entries()
175 let (tx2, rx2) = mpsc::unbounded_channel_stream(); in replace()
178 let rx2 = Box::pin(rx2); in replace() localVariable
184 let _rx1 = map.insert("foo", rx2).unwrap(); in replace()
Dstream_merge.rs27 let (tx2, rx2) = mpsc::unbounded_channel_stream(); in merge_async_streams()
29 let mut rx = task::spawn(rx1.merge(rx2)); in merge_async_streams()
Dstream_chain.rs45 let (tx2, rx2) = mpsc::unbounded_channel_stream(); in pending_first()
47 let mut stream = task::spawn(rx1.chain(rx2)); in pending_first()
/external/kotlinx.coroutines/reactive/
Dknit.properties5 knit.package=kotlinx.coroutines.rx2.guide
6 knit.dir=kotlinx-coroutines-rx2/test/guide/
DREADME.md10 * [kotlinx-coroutines-rx2](kotlinx-coroutines-rx2/README.md) -- utilities for [RxJava 2.x](https://…

123