| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/ |
| D | ObservableSingleTest.kt | 22 val observable = rxObservable { in testSingleNoWait() constant
38 val observable = rxObservable { in testSingleEmitAndAwait() constant
49 val observable = rxObservable { in testSingleWithDelay() constant
60 val observable = rxObservable { in testSingleException() constant
71 val observable = rxObservable { in testAwaitFirst() constant
82 val observable = rxObservable { in testAwaitFirstOrDefault() constant
93 val observable = rxObservable { in testAwaitFirstOrDefaultWithValues() constant
104 val observable = rxObservable<String> { in testAwaitFirstOrNull() constant
115 val observable = rxObservable { in testAwaitFirstOrNullWithValues() constant
126 val observable = rxObservable { in testAwaitFirstOrElse() constant
[all …]
|
| D | ObservableMultiTest.kt | 20 val observable = rxObservable { in <lambda>() constant
32 val observable = rxObservable { in <lambda>() constant
53 val observable = rxObservable(Dispatchers.Unconfined) { in <lambda>() constant
64 val observable = rxObservable { in <lambda>() constant
74 val observable = rxObservable { in <lambda>() constant
|
| D | FlowAsObservableTest.kt | 19 val observable = flow { in <lambda>() constant
36 val observable = flow<Int> { in <lambda>() constant
53 val observable = flow<Int> { in <lambda>() constant
68 val observable = in <lambda>() constant
101 val observable = flow { in <lambda>() constant
123 val observable = flow<Int> { in <lambda>() constant
135 val observable = flow { in <lambda>() constant
|
| D | FlowableTest.kt | 16 val observable = rxFlowable(currentDispatcher()) { in <lambda>() constant
33 val observable = rxFlowable<String>(currentDispatcher()) { in <lambda>() constant
53 val observable = rxFlowable<String>(currentDispatcher()) { in <lambda>() constant
75 val observable = in <lambda>() constant
|
| D | ObservableTest.kt | 25 val observable = rxObservable(currentDispatcher()) { in <lambda>() constant
42 val observable = rxObservable<String>(currentDispatcher()) { in <lambda>() constant
62 val observable = rxObservable<String>(currentDispatcher()) { in <lambda>() constant
84 val observable = in <lambda>() constant
|
| D | IntegrationTest.kt | 42 val observable = rxObservable<String>(ctx(coroutineContext)) { in <lambda>() constant
61 val observable = rxObservable(ctx(coroutineContext)) { in <lambda>() constant
82 val observable = rxObservable(ctx(coroutineContext)) { in <lambda>() constant
|
| D | ObservableSourceAsFlowStressTest.kt | 29 val observable = Observable.interval(100L, TimeUnit.MICROSECONDS) in <lambda>() constant
|
| D | ConvertTest.kt | 130 val observable = c.consumeAsFlow().asObservable() in <lambda>() constant
144 val observable = c.consumeAsFlow().asObservable() in <lambda>() constant
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/ |
| D | ObservableSingleTest.kt | 22 val observable = rxObservable { in testSingleNoWait() constant
38 val observable = rxObservable { in testSingleEmitAndAwait() constant
49 val observable = rxObservable { in testSingleWithDelay() constant
60 val observable = rxObservable { in testSingleException() constant
71 val observable = rxObservable { in testAwaitFirst() constant
82 val observable = rxObservable { in testAwaitFirstOrDefault() constant
93 val observable = rxObservable { in testAwaitFirstOrDefaultWithValues() constant
104 val observable = rxObservable<String> { in testAwaitFirstOrNull() constant
115 val observable = rxObservable { in testAwaitFirstOrNullWithValues() constant
126 val observable = rxObservable { in testAwaitFirstOrElse() constant
[all …]
|
| D | ObservableMultiTest.kt | 20 val observable = rxObservable { in <lambda>() constant
32 val observable = rxObservable { in <lambda>() constant
53 val observable = rxObservable(Dispatchers.Unconfined) { in <lambda>() constant
64 val observable = rxObservable { in <lambda>() constant
74 val observable = rxObservable { in <lambda>() constant
|
| D | FlowAsObservableTest.kt | 19 val observable = flow { in <lambda>() constant
36 val observable = flow<Int> { in <lambda>() constant
53 val observable = flow<Int> { in <lambda>() constant
68 val observable = in <lambda>() constant
101 val observable = flow { in <lambda>() constant
123 val observable = flow<Int> { in <lambda>() constant
135 val observable = flow { in <lambda>() constant
|
| D | FlowableTest.kt | 17 val observable = rxFlowable(currentDispatcher()) { in <lambda>() constant
34 val observable = rxFlowable<String>(currentDispatcher()) { in <lambda>() constant
54 val observable = rxFlowable<String>(currentDispatcher()) { in <lambda>() constant
76 val observable = in <lambda>() constant
|
| D | ObservableTest.kt | 25 val observable = rxObservable(currentDispatcher()) { in <lambda>() constant
42 val observable = rxObservable<String>(currentDispatcher()) { in <lambda>() constant
62 val observable = rxObservable<String>(currentDispatcher()) { in <lambda>() constant
84 val observable = in <lambda>() constant
|
| D | IntegrationTest.kt | 42 val observable = rxObservable<String>(ctx(coroutineContext)) { in <lambda>() constant
61 val observable = rxObservable(ctx(coroutineContext)) { in <lambda>() constant
82 val observable = rxObservable(ctx(coroutineContext)) { in <lambda>() constant
|
| D | ObservableSourceAsFlowStressTest.kt | 28 val observable = Observable.interval(100L, TimeUnit.MICROSECONDS) in <lambda>() constant
|
| D | ConvertTest.kt | 130 val observable = c.consumeAsFlow().asObservable(Dispatchers.Unconfined) in <lambda>() constant
144 val observable = c.consumeAsFlow().asObservable(Dispatchers.Unconfined) in <lambda>() constant
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/ |
| D | PublisherBackpressureTest.kt | 15 val observable = publish(currentDispatcher()) { in <lambda>() constant
|
| D | PublisherMultiTest.kt | 15 val observable = publish { in <lambda>() constant
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/test/ |
| D | PublisherBackpressureTest.kt | 15 val observable = flowPublish(currentDispatcher()) { in <lambda>() constant
|
| D | PublisherMultiTest.kt | 15 val observable = flowPublish { in <lambda>() constant
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/ |
| D | start_with.cpp | 8 auto observable = rxcpp::observable<>::range(10, 12); variable
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/test/ |
| D | FluxTest.kt | 77 val observable = in <lambda>() constant
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-observable.hpp | 482 class observable class
542 observable() in observable() function in rxcpp::observable
546 explicit observable(const source_operator_type& o) in observable() function in rxcpp::observable
550 explicit observable(source_operator_type&& o) in observable() function in rxcpp::observable
557 observable(const observable<T, SO>& o) in observable() function in rxcpp::observable
562 observable(observable<T, SO>&& o) in observable() function in rxcpp::observable
1561 class observable<void, void> class
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/ |
| D | rx-replaysubject.hpp | 172 auto observable = make_observable_dynamic<T>([=](subscriber<T> o){ in get_observable() local
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/subscriptions/ |
| D | subscription.cpp | 16 auto observable = rxcpp::observable<>::create<int>([=](rxcpp::subscriber<int> out){ in __anon442cb92f0102() variable
|