| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/ |
| D | ObservableSingleTest.kt | 24 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 …]
|
| D | ObservableMultiTest.kt | 21 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
|
| 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 | 43 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
|
| 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-rx3/test/ |
| D | ObservableSingleTest.kt | 24 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 …]
|
| D | ObservableMultiTest.kt | 21 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
|
| 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
130 val observable = rxObservable<Int> { 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/grpc-grpc/test/core/promise/ |
| D | observable_test.cc | 90 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/ |
| D | CrtFileUploadTest.java | 105 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/ |
| D | PublisherMultiTest.kt | 16 val observable = publish { in <lambda>() constant
36 val observable = publish<Int> { in <lambda>() constant
|
| D | PublisherBackpressureTest.kt | 15 val observable = publish(currentDispatcher()) { 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/aws-sdk-java-v2/services-custom/s3-transfer-manager/src/main/java/software/amazon/awssdk/transfer/s3/internal/model/ |
| D | CrtFileUpload.java | 40 private final S3MetaRequestPauseObservable observable; field in CrtFileUpload
44 S3MetaRequestPauseObservable observable, in CrtFileUpload()
|
| /external/nullaway/nullaway/src/test/resources/com/uber/nullaway/testdata/ |
| D | NullAwayRxSupportPositiveCases.java | 54 Observable<NullableContainer<String>> observable) { in filterWithIfThenMapNullableContainerNullableOnSomeBranch()
|
| D | NullAwayRxSupportNegativeCases.java | 58 private Observable<Integer> filterThenMap(Observable<String> observable) { in filterThenMap()
|