| /aosp_15_r20/external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/test/ |
| H A D | PublishTest.kt | 20 override fun onSubscribe(s: JFlow.Subscription?) { expect(3) } in <lambda>() method
40 override fun onSubscribe(s: JFlow.Subscription) { in <lambda>() method
65 override fun onSubscribe(s: JFlow.Subscription) { in <lambda>() method
105 override fun onSubscribe(s: JFlow.Subscription) { in <lambda>() method
164 override fun onSubscribe(s: JFlow.Subscription) { in <lambda>() method
201 override fun onSubscribe(s: JFlow.Subscription) { in <lambda>() method
|
| H A D | FlowAsPublisherTest.kt | 29 override fun onSubscribe(s: JFlow.Subscription?) { in testErrorOnCancellationIsReported() method
59 override fun onSubscribe(s: JFlow.Subscription?) { in testCancellationIsNotReported() method
|
| /aosp_15_r20/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/ |
| H A D | RxAwait.kt | 23 override fun onSubscribe(d: Disposable) { cont.disposeOnCancellation(d) } in <lambda>() method
42 override fun onSubscribe(d: Disposable) { cont.disposeOnCancellation(d) } in onSubscribe() method
119 override fun onSubscribe(d: Disposable) { cont.disposeOnCancellation(d) } in onSubscribe() method
225 override fun onSubscribe(sub: Disposable) { in toString() method
|
| /aosp_15_r20/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/ |
| H A D | PublishTest.kt | 24 override fun onSubscribe(s: Subscription?) { expect(3) } in <lambda>() method
44 override fun onSubscribe(s: Subscription) { in <lambda>() method
69 override fun onSubscribe(s: Subscription) { in <lambda>() method
109 override fun onSubscribe(s: Subscription) { in <lambda>() method
168 override fun onSubscribe(s: Subscription) { in <lambda>() method
205 override fun onSubscribe(s: Subscription) { in <lambda>() method
|
| H A D | FlowAsPublisherTest.kt | 30 override fun onSubscribe(s: Subscription?) { in <lambda>() method
60 override fun onSubscribe(s: Subscription?) { in <lambda>() method
87 override fun onSubscribe(s: Subscription) { in <lambda>() method
124 override fun onSubscribe(s: Subscription) { in <lambda>() method
|
| H A D | IterableFlowTckTest.kt | 34 override fun onSubscribe(s: Subscription) { in createFailedPublisher() method
53 override fun onSubscribe(s: Subscription) { in testStackOverflowTrampoline() method
88 override fun onSubscribe(s: Subscription) { in testConcurrentRequest() method
|
| /aosp_15_r20/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/ |
| H A D | RxAwait.kt | 23 override fun onSubscribe(d: Disposable) { in <lambda>() method
50 override fun onSubscribe(d: Disposable) { in awaitSingleOrNull() method
136 override fun onSubscribe(d: Disposable) { in awaitSingle() method
245 override fun onSubscribe(sub: Disposable) { in toString() method
|
| /aosp_15_r20/prebuilts/tools/common/m2/repository/io/reactivex/rxjava2/rxjava/2.2.9/ |
| HD | rxjava-2.2.9.jar | META-INF/
META-INF/MANIFEST.MF
io/
io/reactivex/
io/ ... |
| /aosp_15_r20/external/aws-sdk-java-v2/core/aws-core/src/main/java/software/amazon/awssdk/awscore/eventstream/ |
| H A D | DefaultEventStreamResponseHandlerBuilder.java | 42 private Consumer<SdkPublisher<EventT>> onSubscribe; field in DefaultEventStreamResponseHandlerBuilder
95 public SubBuilderT onEventStream(Consumer<SdkPublisher<EventT>> onSubscribe) { in onEventStream()
|
| /aosp_15_r20/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/ |
| H A D | FlowAsFlowableTest.kt | 23 override fun onSubscribe(s: Subscription) { in <lambda>() method
60 override fun onSubscribe(s: Subscription) { in <lambda>() method
|
| H A D | FlowAsObservableTest.kt | 151 override fun onSubscribe(d: Disposable) { in <lambda>() method
184 override fun onSubscribe(d: Disposable) { in <lambda>() method
|
| /aosp_15_r20/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/ |
| H A D | FlowAsFlowableTest.kt | 23 override fun onSubscribe(s: Subscription) { in <lambda>() method
60 override fun onSubscribe(s: Subscription) { in <lambda>() method
|
| H A D | FlowAsObservableTest.kt | 151 override fun onSubscribe(d: Disposable) { in <lambda>() method
184 override fun onSubscribe(d: Disposable) { in <lambda>() method
|
| /aosp_15_r20/frameworks/base/core/java/android/service/notification/ |
| H A D | ConditionProviderService.java | 137 abstract public void onSubscribe(Uri conditionId); in onSubscribe() method in ConditionProviderService
251 public void onSubscribe(Uri conditionId) { in onSubscribe() method in ConditionProviderService.Provider
|
| H A D | IConditionProvider.aidl | 25 void onSubscribe(in Uri conditionId); in onSubscribe() method
|
| /aosp_15_r20/external/aws-sdk-java-v2/services/s3/src/main/java/software/amazon/awssdk/services/s3/internal/checksums/ |
| H A D | S3ChecksumValidatingPublisher.java | 75 public void onSubscribe(Subscription s) { in onSubscribe() method in S3ChecksumValidatingPublisher.ChecksumValidatingSubscriber
162 public void onSubscribe(Subscription s) { in onSubscribe() method in S3ChecksumValidatingPublisher.ChecksumSkippingSubscriber
|
| /aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/test/java/software/amazon/awssdk/core/async/ |
| H A D | SdkPublishersTest.java | 166 public void onSubscribe(Subscription s) { in onSubscribe() method in SdkPublishersTest.FakeByteBufferSubscriber
198 public void onSubscribe(Subscription s) { in onSubscribe() method in SdkPublishersTest.FakeStringSubscriber
|
| /aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/test/java/software/amazon/awssdk/core/internal/async/ |
| H A D | SplittingPublisherTest.java | 196 public void onSubscribe(Subscription s) { in onSubscribe() method in SplittingPublisherTest.OnlyRequestOnceSubscriber
228 public void onSubscribe(Subscription s) { in onSubscribe() method in SplittingPublisherTest.BaosSubscriber
|
| /aosp_15_r20/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/test/ |
| H A D | FlowAsFluxTest.kt | 86 override fun onSubscribe(s: Subscription) { in <lambda>() method
123 override fun onSubscribe(s: Subscription) { in <lambda>() method
|
| /aosp_15_r20/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/nrs/ |
| H A D | CancelledSubscriber.java | 36 public void onSubscribe(Subscription subscription) { in onSubscribe() method in CancelledSubscriber
|
| /aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/async/ |
| H A D | DrainingSubscriber.java | 29 public void onSubscribe(Subscription subscription) { in onSubscribe() method in DrainingSubscriber
|
| /aosp_15_r20/external/aws-sdk-java-v2/utils/src/test/java/software/amazon/awssdk/utils/async/ |
| H A D | InputStreamSubscriberTckTest.java | 39 public void onSubscribe(Subscription subscription) { in createSubscriber() method in InputStreamSubscriberTckTest
|
| H A D | ByteBufferStoringSubscriberTckTest.java | 39 public void onSubscribe(Subscription subscription) { in createSubscriber() method in ByteBufferStoringSubscriberTckTest
|
| H A D | StoringSubscriberTckTest.java | 38 public void onSubscribe(Subscription subscription) { in createSubscriber() method in StoringSubscriberTckTest
|
| /aosp_15_r20/frameworks/native/libs/bufferstreams/aidl/android/graphics/bufferstreams/ |
| H A D | IBufferSubscriber.aidl | 28 oneway void onSubscribe(in IBufferSubscription subscription); in onSubscribe() method
|