| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/ |
| D | ObservableSingleTest.kt | 22 val observable = rxObservable { in testSingleNoWait() constant
26 checkSingleValue(observable) { in testSingleNoWait()
38 val observable = rxObservable { in testSingleEmitAndAwait() constant
42 checkSingleValue(observable) { in testSingleEmitAndAwait()
49 val observable = rxObservable { in testSingleWithDelay() constant
53 checkSingleValue(observable) { in testSingleWithDelay()
60 val observable = rxObservable { in testSingleException() constant
64 checkErroneous(observable) { in testSingleException()
71 val observable = rxObservable { in testAwaitFirst() constant
75 checkSingleValue(observable) { in testAwaitFirst()
[all …]
|
| D | IntegrationTest.kt | 42 val observable = rxObservable<String>(ctx(coroutineContext)) { in <lambda>() constant
46 assertFailsWith<NoSuchElementException> { observable.awaitFirst() } in <lambda>()
47 assertEquals("OK", observable.awaitFirstOrDefault("OK")) in <lambda>()
48 assertNull(observable.awaitFirstOrNull()) in <lambda>()
49 assertEquals("ELSE", observable.awaitFirstOrElse { "ELSE" }) in <lambda>()
50 assertFailsWith<NoSuchElementException> { observable.awaitLast() } in <lambda>()
51 assertFailsWith<NoSuchElementException> { observable.awaitSingle() } in <lambda>()
53 observable.collect { in <lambda>()
61 val observable = rxObservable(ctx(coroutineContext)) { in <lambda>() constant
65 assertEquals("OK", observable.awaitFirst()) in <lambda>()
[all …]
|
| D | FlowAsObservableTest.kt | 19 val observable = flow { in <lambda>() constant
25 observable.subscribe { value -> in <lambda>()
36 val observable = flow<Int> { in <lambda>() constant
42 observable.subscribe({ expectUnreached() }, { error -> in <lambda>()
53 val observable = flow<Int> { in <lambda>() constant
61 val sub = observable.subscribe({ expectUnreached() }, { expectUnreached() }) in <lambda>()
68 val observable = in <lambda>() constant
87 observable.collect { in <lambda>()
101 val observable = flow { in <lambda>() constant
111 observable.collect { in <lambda>()
[all …]
|
| D | ObservableMultiTest.kt | 20 val observable = rxObservable { in <lambda>() constant
23 checkSingleValue(observable.toList()) { list -> in <lambda>()
32 val observable = rxObservable { in <lambda>() constant
44 checkSingleValue(observable.toList()) { list -> in <lambda>()
53 val observable = rxObservable(Dispatchers.Unconfined) { in <lambda>() constant
56 checkSingleValue(observable.toList()) { list -> in <lambda>()
64 val observable = rxObservable { in <lambda>() constant
67 checkSingleValue(observable.toList()) { list -> in <lambda>()
74 val observable = rxObservable { in <lambda>() constant
81 observable.collect { result += it } in <lambda>()
|
| D | FlowableTest.kt | 16 val observable = rxFlowable(currentDispatcher()) { in <lambda>() constant
21 observable.subscribe { value -> in <lambda>()
33 val observable = rxFlowable<String>(currentDispatcher()) { in <lambda>() constant
38 observable.subscribe({ in <lambda>()
53 val observable = rxFlowable<String>(currentDispatcher()) { in <lambda>() constant
59 val sub = observable.subscribe({ in <lambda>()
75 val observable = in <lambda>() constant
95 observable.collect { in <lambda>()
|
| D | ObservableTest.kt | 25 val observable = rxObservable(currentDispatcher()) { in <lambda>() constant
30 observable.subscribe { value -> in <lambda>()
42 val observable = rxObservable<String>(currentDispatcher()) { in <lambda>() constant
47 observable.subscribe({ in <lambda>()
62 val observable = rxObservable<String>(currentDispatcher()) { in <lambda>() constant
68 val sub = observable.subscribe({ in <lambda>()
84 val observable = in <lambda>() constant
104 observable.collect { in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/ |
| D | ObservableSingleTest.kt | 22 val observable = rxObservable { in testSingleNoWait() constant
26 checkSingleValue(observable) { in testSingleNoWait()
38 val observable = rxObservable { in testSingleEmitAndAwait() constant
42 checkSingleValue(observable) { in testSingleEmitAndAwait()
49 val observable = rxObservable { in testSingleWithDelay() constant
53 checkSingleValue(observable) { in testSingleWithDelay()
60 val observable = rxObservable { in testSingleException() constant
64 checkErroneous(observable) { in testSingleException()
71 val observable = rxObservable { in testAwaitFirst() constant
75 checkSingleValue(observable) { in testAwaitFirst()
[all …]
|
| D | IntegrationTest.kt | 42 val observable = rxObservable<String>(ctx(coroutineContext)) { in <lambda>() constant
46 assertFailsWith<NoSuchElementException> { observable.awaitFirst() } in <lambda>()
47 assertEquals("OK", observable.awaitFirstOrDefault("OK")) in <lambda>()
48 assertNull(observable.awaitFirstOrNull()) in <lambda>()
49 assertEquals("ELSE", observable.awaitFirstOrElse { "ELSE" }) in <lambda>()
50 assertFailsWith<NoSuchElementException> { observable.awaitLast() } in <lambda>()
51 assertFailsWith<NoSuchElementException> { observable.awaitSingle() } in <lambda>()
53 observable.collect { in <lambda>()
61 val observable = rxObservable(ctx(coroutineContext)) { in <lambda>() constant
65 assertEquals("OK", observable.awaitFirst()) in <lambda>()
[all …]
|
| D | FlowAsObservableTest.kt | 19 val observable = flow { in <lambda>() constant
25 observable.subscribe { value -> in <lambda>()
36 val observable = flow<Int> { in <lambda>() constant
42 observable.subscribe({ expectUnreached() }, { error -> in <lambda>()
53 val observable = flow<Int> { in <lambda>() constant
61 val sub = observable.subscribe({ expectUnreached() }, { expectUnreached() }) in <lambda>()
68 val observable = in <lambda>() constant
87 observable.collect { in <lambda>()
101 val observable = flow { in <lambda>() constant
111 observable.collect { in <lambda>()
[all …]
|
| D | ObservableMultiTest.kt | 20 val observable = rxObservable { in <lambda>() constant
23 checkSingleValue(observable.toList()) { list -> in <lambda>()
32 val observable = rxObservable { in <lambda>() constant
44 checkSingleValue(observable.toList()) { list -> in <lambda>()
53 val observable = rxObservable(Dispatchers.Unconfined) { in <lambda>() constant
56 checkSingleValue(observable.toList()) { list -> in <lambda>()
64 val observable = rxObservable { in <lambda>() constant
67 checkSingleValue(observable.toList()) { list -> in <lambda>()
74 val observable = rxObservable { in <lambda>() constant
81 observable.collect { result += it } in <lambda>()
|
| D | FlowableTest.kt | 17 val observable = rxFlowable(currentDispatcher()) { in <lambda>() constant
22 observable.subscribe { value -> in <lambda>()
34 val observable = rxFlowable<String>(currentDispatcher()) { in <lambda>() constant
39 observable.subscribe({ in <lambda>()
54 val observable = rxFlowable<String>(currentDispatcher()) { in <lambda>() constant
60 val sub = observable.subscribe({ in <lambda>()
76 val observable = in <lambda>() constant
96 observable.collect { in <lambda>()
|
| D | ObservableTest.kt | 25 val observable = rxObservable(currentDispatcher()) { in <lambda>() constant
30 observable.subscribe { value -> in <lambda>()
42 val observable = rxObservable<String>(currentDispatcher()) { in <lambda>() constant
47 observable.subscribe({ in <lambda>()
62 val observable = rxObservable<String>(currentDispatcher()) { in <lambda>() constant
68 val sub = observable.subscribe({ in <lambda>()
84 val observable = in <lambda>() constant
104 observable.collect { in <lambda>()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/ |
| D | blocking_observable.cpp | 8 auto values = rxcpp::observable<>::range(1, 3).as_blocking();
16 auto values = rxcpp::observable<>::empty<int>().as_blocking();
28 auto values = rxcpp::observable<>::error<int>(std::runtime_error("Error from source")).
41 auto values = rxcpp::observable<>::range(1, 3).as_blocking();
49 auto values = rxcpp::observable<>::empty<int>().as_blocking();
61 auto values = rxcpp::observable<>::range(1, 3).
62 concat(rxcpp::observable<>::error<int>(std::runtime_error("Error from source"))).
75 auto values = rxcpp::observable<>::range(1, 3).as_blocking();
83 auto values = rxcpp::observable<>::range(1, 3).
84 concat(rxcpp::observable<>::error<int>(std::runtime_error("Error from source"))).
[all …]
|
| D | concat.cpp | 8 auto o1 = rxcpp::observable<>::range(1, 3);
9 auto o2 = rxcpp::observable<>::just(4);
10 auto o3 = rxcpp::observable<>::from(5, 6);
21 auto o1 = rxcpp::observable<>::range(1, 3);
22 auto o2 = rxcpp::observable<>::just(4);
23 auto o3 = rxcpp::observable<>::from(5, 6);
24 auto base = rxcpp::observable<>::from(o1.as_dynamic(), o2, o3);
35 auto o1 = rxcpp::observable<>::range(1, 3);
36 auto o2 = rxcpp::observable<>::just(4);
37 auto o3 = rxcpp::observable<>::from(5, 6);
[all …]
|
| D | window.cpp | 9 auto values = rxcpp::observable<>::range(1, 5).window(2);
12 [&counter](rxcpp::observable<int> v){ in __anon0463d6c70102()
25 auto values = rxcpp::observable<>::range(1, 7).window(2, 3);
28 [&counter](rxcpp::observable<int> v){ in __anon0463d6c70402()
43 …auto values = rxcpp::observable<>::interval(std::chrono::steady_clock::now() + std::chrono::millis…
49 [&counter](rxcpp::observable<long> v){ in __anon0463d6c70702()
64 …auto values = rxcpp::observable<>::interval(std::chrono::steady_clock::now() + std::chrono::millis…
69 [&counter](rxcpp::observable<long> v){ in __anon0463d6c70a02()
84 …auto values = rxcpp::observable<>::interval(std::chrono::steady_clock::now() + std::chrono::millis…
89 [&counter](rxcpp::observable<long> v){ in __anon0463d6c70d02()
[all …]
|
| D | math.cpp | 8 auto values = rxcpp::observable<>::range(1, 3).first();
19 auto values = rxcpp::observable<>::empty<int>().first();
36 auto values = rxcpp::observable<>::range(1, 3).last();
47 auto values = rxcpp::observable<>::empty<int>().last();
64 auto values = rxcpp::observable<>::range(1, 3).count();
75 auto values = rxcpp::observable<>::range(1, 3).
76 concat(rxcpp::observable<>::error<int>(std::runtime_error("Error from source"))).
94 auto values = rxcpp::observable<>::range(1, 3).sum();
105 auto values = rxcpp::observable<>::empty<int>().sum();
122 auto values = rxcpp::observable<>::range(1, 3).
[all …]
|
| D | merge_delay_error.cpp | 11 auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(15)).map([](int) {return 1;}); in __anon404e2e960102()
12 auto o2 = rxcpp::observable<>::error<int>(std::runtime_error("Error from source\n"));
13 auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(5)).map([](int) {return 3;}); in __anon404e2e960202()
25 auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(15)).map([](int) {return 1;}); in __anon404e2e960602()
26 auto o2 = rxcpp::observable<>::error<int>(std::runtime_error("Error from source\n"));
27 auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(5)).map([](int) {return 3;}); in __anon404e2e960702()
28 auto base = rxcpp::observable<>::from(o1.as_dynamic(), o2, o3);
43 auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).map([](long) -> long { in __anon404e2e960b02()
47 …auto o2 = rxcpp::observable<>::timer(std::chrono::milliseconds(20)).flat_map([](long) -> rxcpp::ob… in __anon404e2e960c02()
53 return rxcpp::observable<>::error<long>(std::runtime_error(ss.str())); in __anon404e2e960c02()
[all …]
|
| D | amb.cpp | 8 auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(15)).map([](int) {return 1;}); in __anonbf9fecff0102()
9 auto o2 = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).map([](int) {return 2;}); in __anonbf9fecff0202()
10 auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(5)).map([](int) {return 3;}); in __anonbf9fecff0302()
21 auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(15)).map([](int) {return 1;}); in __anonbf9fecff0602()
22 auto o2 = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).map([](int) {return 2;}); in __anonbf9fecff0702()
23 auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(5)).map([](int) {return 3;}); in __anonbf9fecff0802()
24 auto base = rxcpp::observable<>::from(o1.as_dynamic(), o2, o3);
38 auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(15)).map([](int) { in __anonbf9fecff0b02()
42 auto o2 = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).map([](int) { in __anonbf9fecff0c02()
46 auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(5)).map([](int) { in __anonbf9fecff0d02()
[all …]
|
| D | merge.cpp | 8 auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(15)).map([](int) {return 1;}); in __anon8faf7d3f0102()
9 auto o2 = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).map([](int) {return 2;}); in __anon8faf7d3f0202()
10 auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(5)).map([](int) {return 3;}); in __anon8faf7d3f0302()
21 auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(15)).map([](int) {return 1;}); in __anon8faf7d3f0602()
22 auto o2 = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).map([](int) {return 2;}); in __anon8faf7d3f0702()
23 auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(5)).map([](int) {return 3;}); in __anon8faf7d3f0802()
24 auto base = rxcpp::observable<>::from(o1.as_dynamic(), o2, o3);
38 auto o1 = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).map([](int) { in __anon8faf7d3f0b02()
42 auto o2 = rxcpp::observable<>::timer(std::chrono::milliseconds(20)).map([](int) { in __anon8faf7d3f0c02()
46 auto o3 = rxcpp::observable<>::timer(std::chrono::milliseconds(30)).map([](int) { in __anon8faf7d3f0d02()
[all …]
|
| D | subscribe.cpp | 11 auto values = rxcpp::observable<>::range(1, 3);
21 auto values1 = rxcpp::observable<>::range(1, 3);
22 auto values2 = rxcpp::observable<>::range(4, 6);
30 auto values = rxcpp::observable<>::range(1, 3);
38 auto values = rxcpp::observable<>::range(1, 3).
39 concat(rxcpp::observable<>::error<int>(std::runtime_error("Error from source")));
53 auto values = rxcpp::observable<>::range(1, 3);
63 auto values = rxcpp::observable<>::range(1, 5);
77 auto values = rxcpp::observable<>::range(1, 3).
78 concat(rxcpp::observable<>::error<int>(std::runtime_error("Error from source")));
[all …]
|
| D | combine_latest.cpp | 8 auto o1 = rxcpp::observable<>::interval(std::chrono::milliseconds(2));
9 auto o2 = rxcpp::observable<>::interval(std::chrono::milliseconds(3));
10 auto o3 = rxcpp::observable<>::interval(std::chrono::milliseconds(5));
26 auto o1 = rxcpp::observable<>::interval(std::chrono::milliseconds(2)).map([](int v) { in __anonadd8ac180302()
30 auto o2 = rxcpp::observable<>::interval(std::chrono::milliseconds(3)).map([](int v) { in __anonadd8ac180402()
34 auto o3 = rxcpp::observable<>::interval(std::chrono::milliseconds(5)).map([](int v) { in __anonadd8ac180502()
51 auto o1 = rxcpp::observable<>::interval(std::chrono::milliseconds(2));
52 auto o2 = rxcpp::observable<>::interval(std::chrono::milliseconds(3));
53 auto o3 = rxcpp::observable<>::interval(std::chrono::milliseconds(5));
69 auto o1 = rxcpp::observable<>::interval(std::chrono::milliseconds(2));
[all …]
|
| D | with_latest_from.cpp | 8 auto o1 = rxcpp::observable<>::interval(std::chrono::milliseconds(2));
9 auto o2 = rxcpp::observable<>::interval(std::chrono::milliseconds(3));
10 auto o3 = rxcpp::observable<>::interval(std::chrono::milliseconds(5));
26 auto o1 = rxcpp::observable<>::interval(std::chrono::milliseconds(2)).map([](int v) { in __anon6b5a404a0302()
30 auto o2 = rxcpp::observable<>::interval(std::chrono::milliseconds(3)).map([](int v) { in __anon6b5a404a0402()
34 auto o3 = rxcpp::observable<>::interval(std::chrono::milliseconds(5)).map([](int v) { in __anon6b5a404a0502()
51 auto o1 = rxcpp::observable<>::interval(std::chrono::milliseconds(2));
52 auto o2 = rxcpp::observable<>::interval(std::chrono::milliseconds(3));
53 auto o3 = rxcpp::observable<>::interval(std::chrono::milliseconds(5));
69 auto o1 = rxcpp::observable<>::interval(std::chrono::milliseconds(2));
[all …]
|
| D | zip.cpp | 8 auto o1 = rxcpp::observable<>::interval(std::chrono::milliseconds(1));
9 auto o2 = rxcpp::observable<>::interval(std::chrono::milliseconds(2));
10 auto o3 = rxcpp::observable<>::interval(std::chrono::milliseconds(3));
26 auto o1 = rxcpp::observable<>::interval(std::chrono::milliseconds(1)).map([](int v) { in __anon3bb890620302()
30 auto o2 = rxcpp::observable<>::interval(std::chrono::milliseconds(2)).map([](int v) { in __anon3bb890620402()
34 auto o3 = rxcpp::observable<>::interval(std::chrono::milliseconds(3)).map([](int v) { in __anon3bb890620502()
51 auto o1 = rxcpp::observable<>::interval(std::chrono::milliseconds(1));
52 auto o2 = rxcpp::observable<>::interval(std::chrono::milliseconds(2));
53 auto o3 = rxcpp::observable<>::interval(std::chrono::milliseconds(3));
69 auto o1 = rxcpp::observable<>::interval(std::chrono::milliseconds(1));
[all …]
|
| D | start_with.cpp | 8 auto observable = rxcpp::observable<>::range(10, 12); variable
9 auto values = rxcpp::observable<>::start_with(observable, 1, 2, 3);
19 auto values = rxcpp::observable<>::range(10, 12).
|
| D | buffer.cpp | 8 auto values = rxcpp::observable<>::range(1, 5).buffer(2);
24 auto values = rxcpp::observable<>::range(1, 7).buffer(2, 3);
45 …auto values = rxcpp::observable<>::interval(std::chrono::steady_clock::now() + std::chrono::millis…
71 …auto values = rxcpp::observable<>::interval(std::chrono::steady_clock::now() + std::chrono::millis…
91 …auto values = rxcpp::observable<>::interval(std::chrono::steady_clock::now() + std::chrono::millis…
111 auto values = rxcpp::observable<>::timer(std::chrono::milliseconds(10)).
128 …auto values = rxcpp::observable<>::interval(std::chrono::steady_clock::now() + std::chrono::millis…
147 …auto values = rxcpp::observable<>::interval(std::chrono::steady_clock::now() + std::chrono::millis…
165 auto int1 = rxcpp::observable<>::range(1L, 3L);
166 auto int2 = rxcpp::observable<>::timer(std::chrono::milliseconds(50));
[all …]
|