Home
last modified time | relevance | path

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

12345678910>>...19

/aosp_15_r20/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/
H A DObservableSingleTest.kt21 val observable = rxObservable { in <lambda>() constant
37 val observable = rxObservable { in <lambda>() constant
48 val observable = rxObservable { in <lambda>() constant
59 val observable = rxObservable { in <lambda>() constant
70 val observable = rxObservable { in <lambda>() constant
81 val observable = rxObservable { in <lambda>() constant
92 val observable = rxObservable { in <lambda>() constant
103 val observable = rxObservable { in <lambda>() constant
114 val observable = rxObservable { in <lambda>() constant
125 val observable = rxObservable { in <lambda>() constant
[all …]
H A DFlowAsObservableTest.kt16 val observable = flow { in <lambda>() constant
33 val observable = flow<Int> { in <lambda>() constant
50 val observable = flow<Int> { in <lambda>() constant
65 val observable = in <lambda>() constant
98 val observable = flow { in <lambda>() constant
120 val observable = flow<Int> { in <lambda>() constant
132 val observable = flow { in <lambda>() constant
H A DObservableMultiTest.kt18 val observable = rxObservable { in <lambda>() constant
30 val observable = rxObservable { in <lambda>() constant
51 val observable = rxObservable<Int> { in <lambda>() constant
74 val observable = rxObservable(Dispatchers.Unconfined) { in <lambda>() constant
85 val observable = rxObservable { in <lambda>() constant
95 val observable = rxObservable { in <lambda>() constant
H A DFlowableTest.kt14 val observable = rxFlowable(currentDispatcher()) { in <lambda>() constant
31 val observable = rxFlowable<String>(currentDispatcher()) { in <lambda>() constant
51 val observable = rxFlowable<String>(currentDispatcher()) { in <lambda>() constant
73 val observable = in <lambda>() constant
H A DObservableTest.kt22 val observable = rxObservable(currentDispatcher()) { in <lambda>() constant
39 val observable = rxObservable<String>(currentDispatcher()) { in <lambda>() constant
59 val observable = rxObservable<String>(currentDispatcher()) { in <lambda>() constant
81 val observable = in <lambda>() constant
H A DIntegrationTest.kt40 val observable = rxObservable<String>(ctx(coroutineContext)) { in <lambda>() constant
59 val observable = rxObservable(ctx(coroutineContext)) { in <lambda>() constant
80 val observable = rxObservable(ctx(coroutineContext)) { in <lambda>() constant
127 val observable = rxObservable<Int> { in <lambda>() constant
H A DConvertTest.kt127 val observable = c.consumeAsFlow().asObservable(Dispatchers.Unconfined) in <lambda>() constant
141 val observable = c.consumeAsFlow().asObservable(Dispatchers.Unconfined) in <lambda>() constant
H A DObservableSourceAsFlowStressTest.kt25 val observable = Observable.interval(100L, TimeUnit.MICROSECONDS) in <lambda>() constant
/aosp_15_r20/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/
H A DObservableSingleTest.kt21 val observable = rxObservable { in <lambda>() constant
37 val observable = rxObservable { in <lambda>() constant
48 val observable = rxObservable { in <lambda>() constant
59 val observable = rxObservable { in <lambda>() constant
70 val observable = rxObservable { in <lambda>() constant
81 val observable = rxObservable { in <lambda>() constant
92 val observable = rxObservable { in <lambda>() constant
103 val observable = rxObservable { in <lambda>() constant
114 val observable = rxObservable { in <lambda>() constant
125 val observable = rxObservable { in <lambda>() constant
[all …]
H A DFlowAsObservableTest.kt16 val observable = flow { in <lambda>() constant
33 val observable = flow<Int> { in <lambda>() constant
50 val observable = flow<Int> { in <lambda>() constant
65 val observable = in <lambda>() constant
98 val observable = flow { in <lambda>() constant
120 val observable = flow<Int> { in <lambda>() constant
132 val observable = flow { in <lambda>() constant
H A DObservableMultiTest.kt18 val observable = rxObservable { in <lambda>() constant
30 val observable = rxObservable { in <lambda>() constant
51 val observable = rxObservable<Int> { in <lambda>() constant
74 val observable = rxObservable(Dispatchers.Unconfined) { in <lambda>() constant
85 val observable = rxObservable { in <lambda>() constant
95 val observable = rxObservable { in <lambda>() constant
H A DFlowableTest.kt13 val observable = rxFlowable(currentDispatcher()) { in <lambda>() constant
30 val observable = rxFlowable<String>(currentDispatcher()) { in <lambda>() constant
50 val observable = rxFlowable<String>(currentDispatcher()) { in <lambda>() constant
72 val observable = in <lambda>() constant
H A DObservableTest.kt22 val observable = rxObservable(currentDispatcher()) { in <lambda>() constant
39 val observable = rxObservable<String>(currentDispatcher()) { in <lambda>() constant
59 val observable = rxObservable<String>(currentDispatcher()) { in <lambda>() constant
81 val observable = in <lambda>() constant
H A DIntegrationTest.kt39 val observable = rxObservable<String>(ctx(coroutineContext)) { in <lambda>() constant
58 val observable = rxObservable(ctx(coroutineContext)) { in <lambda>() constant
79 val observable = rxObservable(ctx(coroutineContext)) { in <lambda>() constant
127 val observable = rxObservable<Int> { in <lambda>() constant
H A DConvertTest.kt127 val observable = c.consumeAsFlow().asObservable() in <lambda>() constant
141 val observable = c.consumeAsFlow().asObservable() in <lambda>() constant
H A DObservableSourceAsFlowStressTest.kt25 val observable = Observable.interval(100L, TimeUnit.MICROSECONDS) in <lambda>() constant
/aosp_15_r20/external/grpc-grpc/test/core/promise/
H A Dobservable_test.cc90 Observable<int> observable(1); in TEST() local
96 Observable<int> observable(0); in TEST() local
103 Observable<int> observable(0); in TEST() local
112 Observable<int> observable(1); in TEST() local
123 Observable<int> observable(1); in TEST() local
135 Observable<int> observable(1); in TEST() local
150 Observable<int> observable(1); in TEST() local
192 Observable<uint64_t> observable(0); in TEST() local
/aosp_15_r20/external/aws-sdk-java-v2/services-custom/s3-transfer-manager/src/test/java/software/amazon/awssdk/transfer/s3/internal/
H A DCrtFileUploadTest.java105 S3MetaRequestPauseObservable observable = new S3MetaRequestPauseObservable(); in pause_futureCompleted_shouldReturnNormally() local
134 S3MetaRequestPauseObservable observable = new S3MetaRequestPauseObservable(); in pauseTwice_shouldReturnTheSame() local
157 S3MetaRequestPauseObservable observable = new S3MetaRequestPauseObservable(); in pause_crtThrowException_shouldPropogate() local
176 S3MetaRequestPauseObservable observable = new S3MetaRequestPauseObservable(); in pause_futureNotComplete_shouldPause() local
207 S3MetaRequestPauseObservable observable = new S3MetaRequestPauseObservable(); in pause_singlePart_shouldPause() local
/aosp_15_r20/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/
H A DPublisherMultiTest.kt13 val observable = publish { in <lambda>() constant
33 val observable = publish<Int> { in <lambda>() constant
H A DPublisherBackpressureTest.kt12 val observable = publish(currentDispatcher()) { in <lambda>() constant
/aosp_15_r20/prebuilts/tools/common/m2/repository/io/reactivex/rxjava2/rxjava/2.2.9/
HDrxjava-2.2.9.jar ... .lang.Object apply (io.reactivex.Observable) } io/reactivex/MaybeObserver.class MaybeObserver ...
/aosp_15_r20/cts/tests/tests/database/src/android/database/cts/
H A DObservableTest.java32 MockObservable observable = new MockObservable(); in testRegisterUnRegisterObserver() local
80 MockObservable observable = new MockObservable(); in testUnregisterAll() local
/aosp_15_r20/external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/test/
H A DPublisherBackpressureTest.kt12 val observable = flowPublish(currentDispatcher()) { in <lambda>() constant
H A DPublisherMultiTest.kt12 val observable = flowPublish { in <lambda>() constant
/aosp_15_r20/external/aws-sdk-java-v2/services-custom/s3-transfer-manager/src/main/java/software/amazon/awssdk/transfer/s3/internal/model/
H A DCrtFileUpload.java40 private final S3MetaRequestPauseObservable observable; field in CrtFileUpload
44 S3MetaRequestPauseObservable observable, in CrtFileUpload()

12345678910>>...19