Home
last modified time | relevance | path

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

12

/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/
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 …]
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
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
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
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
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
DObservableSourceAsFlowStressTest.kt25 val observable = Observable.interval(100L, TimeUnit.MICROSECONDS) in <lambda>() constant
DConvertTest.kt127 val observable = c.consumeAsFlow().asObservable() in <lambda>() constant
141 val observable = c.consumeAsFlow().asObservable() in <lambda>() constant
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/
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 …]
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
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
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
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
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
DObservableSourceAsFlowStressTest.kt25 val observable = Observable.interval(100L, TimeUnit.MICROSECONDS) in <lambda>() constant
DConvertTest.kt127 val observable = c.consumeAsFlow().asObservable(Dispatchers.Unconfined) in <lambda>() constant
141 val observable = c.consumeAsFlow().asObservable(Dispatchers.Unconfined) in <lambda>() constant
/external/grpc-grpc/test/core/promise/
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
/external/aws-sdk-java-v2/services-custom/s3-transfer-manager/src/test/java/software/amazon/awssdk/transfer/s3/internal/
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
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/
DPublisherMultiTest.kt13 val observable = publish { in <lambda>() constant
33 val observable = publish<Int> { in <lambda>() constant
DPublisherBackpressureTest.kt12 val observable = publish(currentDispatcher()) { in <lambda>() constant
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/test/
DPublisherBackpressureTest.kt12 val observable = flowPublish(currentDispatcher()) { in <lambda>() constant
DPublisherMultiTest.kt12 val observable = flowPublish { in <lambda>() constant
/external/aws-sdk-java-v2/services-custom/s3-transfer-manager/src/main/java/software/amazon/awssdk/transfer/s3/internal/model/
DCrtFileUpload.java40 private final S3MetaRequestPauseObservable observable; field in CrtFileUpload
44 S3MetaRequestPauseObservable observable, in CrtFileUpload()
/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()

12