Home
last modified time | relevance | path

Searched refs:observable (Results 1 – 25 of 133) sorted by relevance

123456

/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/
DObservableSingleTest.kt21 val observable = rxObservable { in <lambda>() constant
25 checkSingleValue(observable) { in <lambda>()
37 val observable = rxObservable { in <lambda>() constant
41 checkSingleValue(observable) { in <lambda>()
48 val observable = rxObservable { in <lambda>() constant
52 checkSingleValue(observable) { in <lambda>()
59 val observable = rxObservable { in <lambda>() constant
63 checkErroneous(observable) { in <lambda>()
70 val observable = rxObservable { in <lambda>() constant
74 checkSingleValue(observable) { in <lambda>()
[all …]
DIntegrationTest.kt39 val observable = rxObservable<String>(ctx(coroutineContext)) { in <lambda>() constant
43 assertFailsWith<NoSuchElementException> { observable.awaitFirst() } in <lambda>()
44 assertEquals("OK", observable.awaitFirstOrDefault("OK")) in <lambda>()
45 assertNull(observable.awaitFirstOrNull()) in <lambda>()
46 assertEquals("ELSE", observable.awaitFirstOrElse { "ELSE" }) in <lambda>()
47 assertFailsWith<NoSuchElementException> { observable.awaitLast() } in <lambda>()
48 assertFailsWith<NoSuchElementException> { observable.awaitSingle() } in <lambda>()
50 observable.collect { in <lambda>()
58 val observable = rxObservable(ctx(coroutineContext)) { in <lambda>() constant
62 assertEquals("OK", observable.awaitFirst()) in <lambda>()
[all …]
DObservableMultiTest.kt18 val observable = rxObservable { in <lambda>() constant
21 checkSingleValue(observable.toList()) { list -> in <lambda>()
30 val observable = rxObservable { in <lambda>() constant
42 checkSingleValue(observable.toList()) { list -> in <lambda>()
51 val observable = rxObservable<Int> { in <lambda>() constant
65 checkSingleValue(observable.toList()) { list -> in <lambda>()
74 val observable = rxObservable(Dispatchers.Unconfined) { in <lambda>() constant
77 checkSingleValue(observable.toList()) { list -> in <lambda>()
85 val observable = rxObservable { in <lambda>() constant
88 checkSingleValue(observable.toList()) { list -> in <lambda>()
[all …]
DFlowAsObservableTest.kt16 val observable = flow { in <lambda>() constant
22 observable.subscribe { value -> in <lambda>()
33 val observable = flow<Int> { in <lambda>() constant
39 observable.subscribe({ expectUnreached() }, { error -> in <lambda>()
50 val observable = flow<Int> { in <lambda>() constant
58 val sub = observable.subscribe({ expectUnreached() }, { expectUnreached() }) in <lambda>()
65 val observable = in <lambda>() constant
84 observable.collect { in <lambda>()
98 val observable = flow { in <lambda>() constant
108 observable.collect { in <lambda>()
[all …]
DFlowableTest.kt13 val observable = rxFlowable(currentDispatcher()) { in <lambda>() constant
18 observable.subscribe { value -> in <lambda>()
30 val observable = rxFlowable<String>(currentDispatcher()) { in <lambda>() constant
35 observable.subscribe({ in <lambda>()
50 val observable = rxFlowable<String>(currentDispatcher()) { in <lambda>() constant
56 val sub = observable.subscribe({ in <lambda>()
72 val observable = in <lambda>() constant
92 observable.collect { in <lambda>()
DObservableTest.kt22 val observable = rxObservable(currentDispatcher()) { in <lambda>() constant
27 observable.subscribe { value -> in <lambda>()
39 val observable = rxObservable<String>(currentDispatcher()) { in <lambda>() constant
44 observable.subscribe({ in <lambda>()
59 val observable = rxObservable<String>(currentDispatcher()) { in <lambda>() constant
65 val sub = observable.subscribe({ in <lambda>()
81 val observable = in <lambda>() constant
101 observable.collect { in <lambda>()
DCheck.kt7 observable: Observable<T>, in checkSingleValue()
10 val singleValue = observable.blockingSingle() in checkSingleValue()
15 observable: Observable<*>, in checkErroneous()
18 val singleNotification = observable.materialize().blockingSingle() in checkErroneous()
DConvertTest.kt127 val observable = c.consumeAsFlow().asObservable() in <lambda>() constant
128 checkSingleValue(observable.reduce { t1, t2 -> t1 + t2 }.toSingle()) { in <lambda>()
141 val observable = c.consumeAsFlow().asObservable() in <lambda>() constant
145 observable.collect { result += it } in <lambda>()
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/
DObservableSingleTest.kt21 val observable = rxObservable { in <lambda>() constant
25 checkSingleValue(observable) { in <lambda>()
37 val observable = rxObservable { in <lambda>() constant
41 checkSingleValue(observable) { in <lambda>()
48 val observable = rxObservable { in <lambda>() constant
52 checkSingleValue(observable) { in <lambda>()
59 val observable = rxObservable { in <lambda>() constant
63 checkErroneous(observable) { in <lambda>()
70 val observable = rxObservable { in <lambda>() constant
74 checkSingleValue(observable) { in <lambda>()
[all …]
DIntegrationTest.kt40 val observable = rxObservable<String>(ctx(coroutineContext)) { in <lambda>() constant
44 assertFailsWith<NoSuchElementException> { observable.awaitFirst() } in <lambda>()
45 assertEquals("OK", observable.awaitFirstOrDefault("OK")) in <lambda>()
46 assertNull(observable.awaitFirstOrNull()) in <lambda>()
47 assertEquals("ELSE", observable.awaitFirstOrElse { "ELSE" }) in <lambda>()
48 assertFailsWith<NoSuchElementException> { observable.awaitLast() } in <lambda>()
49 assertFailsWith<NoSuchElementException> { observable.awaitSingle() } in <lambda>()
51 observable.collect { in <lambda>()
59 val observable = rxObservable(ctx(coroutineContext)) { in <lambda>() constant
63 assertEquals("OK", observable.awaitFirst()) in <lambda>()
[all …]
DObservableMultiTest.kt18 val observable = rxObservable { in <lambda>() constant
21 checkSingleValue(observable.toList()) { list -> in <lambda>()
30 val observable = rxObservable { in <lambda>() constant
42 checkSingleValue(observable.toList()) { list -> in <lambda>()
51 val observable = rxObservable<Int> { in <lambda>() constant
65 checkSingleValue(observable.toList()) { list -> in <lambda>()
74 val observable = rxObservable(Dispatchers.Unconfined) { in <lambda>() constant
77 checkSingleValue(observable.toList()) { list -> in <lambda>()
85 val observable = rxObservable { in <lambda>() constant
88 checkSingleValue(observable.toList()) { list -> in <lambda>()
[all …]
DFlowAsObservableTest.kt16 val observable = flow { in <lambda>() constant
22 observable.subscribe { value -> in <lambda>()
33 val observable = flow<Int> { in <lambda>() constant
39 observable.subscribe({ expectUnreached() }, { error -> in <lambda>()
50 val observable = flow<Int> { in <lambda>() constant
58 val sub = observable.subscribe({ expectUnreached() }, { expectUnreached() }) in <lambda>()
65 val observable = in <lambda>() constant
84 observable.collect { in <lambda>()
98 val observable = flow { in <lambda>() constant
108 observable.collect { in <lambda>()
[all …]
DFlowableTest.kt14 val observable = rxFlowable(currentDispatcher()) { in <lambda>() constant
19 observable.subscribe { value -> in <lambda>()
31 val observable = rxFlowable<String>(currentDispatcher()) { in <lambda>() constant
36 observable.subscribe({ in <lambda>()
51 val observable = rxFlowable<String>(currentDispatcher()) { in <lambda>() constant
57 val sub = observable.subscribe({ in <lambda>()
73 val observable = in <lambda>() constant
93 observable.collect { in <lambda>()
DObservableTest.kt22 val observable = rxObservable(currentDispatcher()) { in <lambda>() constant
27 observable.subscribe { value -> in <lambda>()
39 val observable = rxObservable<String>(currentDispatcher()) { in <lambda>() constant
44 observable.subscribe({ in <lambda>()
59 val observable = rxObservable<String>(currentDispatcher()) { in <lambda>() constant
65 val sub = observable.subscribe({ in <lambda>()
81 val observable = in <lambda>() constant
101 observable.collect { in <lambda>()
DCheck.kt8 observable: Observable<T>, in checkSingleValue()
11 val singleValue = observable.blockingSingle() in checkSingleValue()
16 observable: Observable<*>, in checkErroneous()
19 val singleNotification = observable.materialize().blockingSingle() in checkErroneous()
DConvertTest.kt127 val observable = c.consumeAsFlow().asObservable(Dispatchers.Unconfined) in <lambda>() constant
128 checkSingleValue(observable.reduce { t1, t2 -> t1 + t2 }.toSingle()) { in <lambda>()
141 val observable = c.consumeAsFlow().asObservable(Dispatchers.Unconfined) in <lambda>() constant
145 observable.collect { result += it } in <lambda>()
/external/grpc-grpc/test/core/promise/
Dobservable_test.cc90 Observable<int> observable(1); in TEST() local
91 auto next = observable.Next(0); in TEST()
96 Observable<int> observable(0); in TEST() local
97 auto next = observable.Next(0); in TEST()
98 observable.Set(1); in TEST()
103 Observable<int> observable(0); in TEST() local
104 observable.Set(1); in TEST()
105 auto next = observable.Next(0); in TEST()
112 Observable<int> observable(1); in TEST() local
113 auto next = observable.Next(1); in TEST()
[all …]
/external/nullaway/nullaway/src/test/resources/com/uber/nullaway/testdata/
DNullAwayRxSupportNegativeCases.java58 private Observable<Integer> filterThenMap(Observable<String> observable) { in filterThenMap() argument
59 return observable in filterThenMap()
77 Observable<NullableContainer<String>> observable) {
78 return observable
100 Observable<NullableContainer<String>> observable) {
101 return observable
119 Observable<NullableContainer<NullableContainer<String>>> observable) {
120 return observable
140 Observable<NullableContainer<String>> observable) {
141 return observable
[all …]
DNullAwayRxSupportPositiveCases.java54 Observable<NullableContainer<String>> observable) { in filterWithIfThenMapNullableContainerNullableOnSomeBranch() argument
55 return observable in filterWithIfThenMapNullableContainerNullableOnSomeBranch()
78 Observable<NullableContainer<String>> observable) {
79 return observable
102 Observable<NullableContainer<String>> observable) {
103 return observable
121 private Observable<Integer> filterWithLambdaNullExpressionBody(Observable<String> observable) {
124 return observable.map(o -> perhaps() ? o : null).map(o -> o.length());
128 Observable<NullableContainer<String>> observable) {
130 return observable.filter(c -> c.get() != null || perhaps()).map(c -> c.get().length());
[all …]
DNullAwayStreamSupportNegativeCases.java195 private Stream<Integer> filterThenMapDoesntBreakWithNonAnnonClass(Stream<String> observable) {
196 return observable
209 private Stream<Integer> filterThenMapLambdas(Stream<String> observable) {
210 return observable.filter(s -> s != null).map(s -> s.length());
214 Stream<NullableContainer<String>> observable) {
215 return observable.filter(c -> c.get() != null).map(c -> c.get().length());
219 Stream<NullableContainer<String>> observable) {
220 return observable
233 Stream<NullableContainer<String>> observable) {
234 return observable
[all …]
/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
110 new CrtFileUpload(future, transferProgress, observable, request); in pause_futureCompleted_shouldReturnNormally()
112 observable.subscribe(metaRequest); in pause_futureCompleted_shouldReturnNormally()
134 S3MetaRequestPauseObservable observable = new S3MetaRequestPauseObservable(); in pauseTwice_shouldReturnTheSame() local
136 observable.subscribe(metaRequest); in pauseTwice_shouldReturnTheSame()
139 new CrtFileUpload(future, transferProgress, observable, request); in pauseTwice_shouldReturnTheSame()
157 S3MetaRequestPauseObservable observable = new S3MetaRequestPauseObservable(); in pause_crtThrowException_shouldPropogate() local
160 observable.subscribe(metaRequest); in pause_crtThrowException_shouldPropogate()
163 new CrtFileUpload(future, transferProgress, observable, request); in pause_crtThrowException_shouldPropogate()
176 S3MetaRequestPauseObservable observable = new S3MetaRequestPauseObservable(); in pause_futureNotComplete_shouldPause() local
[all …]
/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() argument
48 this.observable = Validate.paramNotNull(observable, "observable"); in CrtFileUpload()
74 token = observable.pause(); in doPause()
136 return observable == that.observable; in equals()
145 result = 31 * result + observable.hashCode(); in hashCode()
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/
DPublisherMultiTest.kt13 val observable = publish { in <lambda>() constant
24 observable.collect { in <lambda>()
33 val observable = publish<Int> { in <lambda>() constant
46 observable.collect { in <lambda>()
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/
DREADME.md12 | [rxObservable] | `Observable` | [ProducerScope] | Cold observable th…
13 | [rxFlowable] | `Flowable` | [ProducerScope] | Cold observable th…
31 …t][io.reactivex.ObservableSource.awaitFirst] | Awaits for the first value from the given observable
32 …rvableSource.awaitFirstOrDefault] | Awaits for the first value from the given observable or default
33 …leSource.awaitFirstOrElse] | Awaits for the first value from the given observable or default from …
34 …x.ObservableSource.awaitFirstOrNull] | Awaits for the first value from the given observable or null
35 …st][io.reactivex.ObservableSource.awaitFirst] | Awaits for the last value from the given observable
36 …[io.reactivex.ObservableSource.awaitSingle] | Awaits for the single value from the given observable
70 …linlang.org/api/kotlinx.coroutines/kotlinx-coroutines-rx2/kotlinx.coroutines.rx2/rx-observable.html
73 …linlang.org/api/kotlinx.coroutines/kotlinx-coroutines-rx2/kotlinx.coroutines.rx2/as-observable.html
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/
DREADME.md12 | [rxObservable] | `Observable` | [ProducerScope] | Cold observable th…
13 | [rxFlowable] | `Flowable` | [ProducerScope] | Cold observable th…
31 …ex.rxjava3.core.ObservableSource.awaitFirst] | Awaits for the first value from the given observable
32 …rvableSource.awaitFirstOrDefault] | Awaits for the first value from the given observable or default
33 …leSource.awaitFirstOrElse] | Awaits for the first value from the given observable or default from …
34 …e.ObservableSource.awaitFirstOrNull] | Awaits for the first value from the given observable or null
35 …vex.rxjava3.core.ObservableSource.awaitFirst] | Awaits for the last value from the given observable
36 ….rxjava3.core.ObservableSource.awaitSingle] | Awaits for the single value from the given observable
70 …linlang.org/api/kotlinx.coroutines/kotlinx-coroutines-rx3/kotlinx.coroutines.rx3/rx-observable.html
73 …linlang.org/api/kotlinx.coroutines/kotlinx-coroutines-rx3/kotlinx.coroutines.rx3/as-observable.html

123456