Home
last modified time | relevance | path

Searched defs:observable (Results 1 – 25 of 29) sorted by relevance

12

/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/
DObservableSingleTest.kt24 val observable = rxObservable { in <lambda>() constant
40 val observable = rxObservable { in <lambda>() constant
51 val observable = rxObservable { in <lambda>() constant
62 val observable = rxObservable { in <lambda>() constant
73 val observable = rxObservable { in <lambda>() constant
84 val observable = rxObservable { in <lambda>() constant
95 val observable = rxObservable { in <lambda>() constant
106 val observable = rxObservable { in <lambda>() constant
117 val observable = rxObservable { in <lambda>() constant
128 val observable = rxObservable { in <lambda>() constant
[all …]
DFlowAsObservableTest.kt19 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
DObservableMultiTest.kt21 val observable = rxObservable { in <lambda>() constant
33 val observable = rxObservable { in <lambda>() constant
54 val observable = rxObservable<Int> { in <lambda>() constant
77 val observable = rxObservable(Dispatchers.Unconfined) { in <lambda>() constant
88 val observable = rxObservable { in <lambda>() constant
98 val observable = rxObservable { in <lambda>() constant
DFlowableTest.kt16 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
DObservableTest.kt25 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
DIntegrationTest.kt42 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
130 val observable = rxObservable<Int> { in <lambda>() constant
DObservableSourceAsFlowStressTest.kt29 val observable = Observable.interval(100L, TimeUnit.MICROSECONDS) in <lambda>() constant
DConvertTest.kt130 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/
DObservableSingleTest.kt24 val observable = rxObservable { in <lambda>() constant
40 val observable = rxObservable { in <lambda>() constant
51 val observable = rxObservable { in <lambda>() constant
62 val observable = rxObservable { in <lambda>() constant
73 val observable = rxObservable { in <lambda>() constant
84 val observable = rxObservable { in <lambda>() constant
95 val observable = rxObservable { in <lambda>() constant
106 val observable = rxObservable { in <lambda>() constant
117 val observable = rxObservable { in <lambda>() constant
128 val observable = rxObservable { in <lambda>() constant
[all …]
DFlowAsObservableTest.kt19 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
DObservableMultiTest.kt21 val observable = rxObservable { in <lambda>() constant
33 val observable = rxObservable { in <lambda>() constant
54 val observable = rxObservable<Int> { in <lambda>() constant
77 val observable = rxObservable(Dispatchers.Unconfined) { in <lambda>() constant
88 val observable = rxObservable { in <lambda>() constant
98 val observable = rxObservable { in <lambda>() constant
DFlowableTest.kt17 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
DObservableTest.kt25 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
DIntegrationTest.kt43 val observable = rxObservable<String>(ctx(coroutineContext)) { in <lambda>() constant
62 val observable = rxObservable(ctx(coroutineContext)) { in <lambda>() constant
83 val observable = rxObservable(ctx(coroutineContext)) { in <lambda>() constant
130 val observable = rxObservable<Int> { in <lambda>() constant
DObservableSourceAsFlowStressTest.kt28 val observable = Observable.interval(100L, TimeUnit.MICROSECONDS) in <lambda>() constant
DConvertTest.kt130 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/
DPublisherMultiTest.kt16 val observable = publish { in <lambda>() constant
36 val observable = publish<Int> { in <lambda>() constant
DPublisherBackpressureTest.kt15 val observable = publish(currentDispatcher()) { in <lambda>() constant
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/test/
DPublisherBackpressureTest.kt15 val observable = flowPublish(currentDispatcher()) { in <lambda>() constant
DPublisherMultiTest.kt15 val observable = flowPublish { in <lambda>() constant
/external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/
Dstart_with.cpp8 auto observable = rxcpp::observable<>::range(10, 12); variable
/external/nullaway/nullaway/src/test/resources/com/uber/nullaway/testdata/
DNullAwayRxSupportPositiveCases.java54 Observable<NullableContainer<String>> observable) { in filterWithIfThenMapNullableContainerNullableOnSomeBranch()
DNullAwayRxSupportNegativeCases.java58 private Observable<Integer> filterThenMap(Observable<String> observable) { in filterThenMap()
/external/armnn/src/armnn/
DGraph.hpp208 void AttachObservable(IGraphObservable* const observable, GraphEvent notifyOnEvent) { in AttachObservable()
212 void DetachObservable(IGraphObservable* const observable, GraphEvent notifyOnEvent) { in DetachObservable()
247 for (auto& observable : m_Views[event]) in NotifyObservables() local
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/test/
DFluxTest.kt77 val observable = in <lambda>() constant

12