| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/ |
| D | RxAwait.kt | 27 override fun onSubscribe(d: Disposable) { cont.disposeOnCancellation(d) } in <lambda>() method
46 override fun onSubscribe(d: Disposable) { cont.disposeOnCancellation(d) } in onSubscribe() method
123 override fun onSubscribe(d: Disposable) { cont.disposeOnCancellation(d) } in onSubscribe() method
229 override fun onSubscribe(sub: Disposable) { in toString() method
|
| D | RxChannel.kt | 70 override fun onSubscribe(sub: Disposable) { in onSubscribe() method
|
| D | RxConvert.kt | 79 … override fun onSubscribe(d: Disposable) { if (!disposableRef.compareAndSet(null, d)) d.dispose() } in <lambda>() method
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/ |
| D | RxAwait.kt | 27 override fun onSubscribe(d: Disposable) { in <lambda>() method
54 override fun onSubscribe(d: Disposable) { in awaitSingleOrNull() method
140 override fun onSubscribe(d: Disposable) { in awaitSingle() method
249 override fun onSubscribe(sub: Disposable) { in toString() method
|
| D | RxChannel.kt | 58 override fun onSubscribe(sub: Disposable) { in onSubscribe() method
|
| D | RxConvert.kt | 79 … override fun onSubscribe(d: Disposable) { if (!disposableRef.compareAndSet(null, d)) d.dispose() } in <lambda>() method
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/ |
| D | FlowAsPublisherTest.kt | 33 override fun onSubscribe(s: Subscription?) { in <lambda>() method
63 override fun onSubscribe(s: Subscription?) { in <lambda>() method
90 override fun onSubscribe(s: Subscription) { in <lambda>() method
127 override fun onSubscribe(s: Subscription) { in <lambda>() method
|
| D | PublishTest.kt | 26 override fun onSubscribe(s: Subscription?) { expect(3) } in <lambda>() method
46 override fun onSubscribe(s: Subscription) { in <lambda>() method
71 override fun onSubscribe(s: Subscription) { in <lambda>() method
111 override fun onSubscribe(s: Subscription) { in <lambda>() method
170 override fun onSubscribe(s: Subscription) { in <lambda>() method
207 override fun onSubscribe(s: Subscription) { in <lambda>() method
|
| D | IterableFlowTckTest.kt | 38 override fun onSubscribe(s: Subscription) { in createFailedPublisher() method
57 override fun onSubscribe(s: Subscription) { in testStackOverflowTrampoline() method
92 override fun onSubscribe(s: Subscription) { in testConcurrentRequest() method
|
| D | PublisherBackpressureTest.kt | 31 override fun onSubscribe(s: Subscription) { in <lambda>() method
|
| D | PublisherRequestStressTest.kt | 80 override fun onSubscribe(sub: Subscription) { in <lambda>() method
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/test/ |
| D | PublishTest.kt | 22 override fun onSubscribe(s: JFlow.Subscription?) { expect(3) } in <lambda>() method
42 override fun onSubscribe(s: JFlow.Subscription) { in <lambda>() method
67 override fun onSubscribe(s: JFlow.Subscription) { in <lambda>() method
107 override fun onSubscribe(s: JFlow.Subscription) { in <lambda>() method
166 override fun onSubscribe(s: JFlow.Subscription) { in <lambda>() method
203 override fun onSubscribe(s: JFlow.Subscription) { in <lambda>() method
|
| D | FlowAsPublisherTest.kt | 32 override fun onSubscribe(s: JFlow.Subscription?) { in testErrorOnCancellationIsReported() method
62 override fun onSubscribe(s: JFlow.Subscription?) { in testCancellationIsNotReported() method
|
| D | PublisherBackpressureTest.kt | 31 override fun onSubscribe(s: JFlow.Subscription) { in <lambda>() method
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/ |
| D | FlowAsFlowableTest.kt | 26 override fun onSubscribe(s: Subscription) { in <lambda>() method
63 override fun onSubscribe(s: Subscription) { in <lambda>() method
|
| D | FlowAsObservableTest.kt | 154 override fun onSubscribe(d: Disposable) { in <lambda>() method
187 override fun onSubscribe(d: Disposable) { in <lambda>() method
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/ |
| D | FlowAsFlowableTest.kt | 26 override fun onSubscribe(s: Subscription) { in <lambda>() method
63 override fun onSubscribe(s: Subscription) { in <lambda>() method
|
| D | FlowAsObservableTest.kt | 154 override fun onSubscribe(d: Disposable) { in <lambda>() method
187 override fun onSubscribe(d: Disposable) { in <lambda>() method
|
| D | CompletableTest.kt | 165 override fun onSubscribe(d: Disposable) { in <lambda>() method
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/test/ |
| D | FlowAsFluxTest.kt | 85 override fun onSubscribe(s: Subscription) { in <lambda>() method
122 override fun onSubscribe(s: Subscription) { in <lambda>() method
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/ |
| D | Channel.kt | 71 override fun onSubscribe(s: Subscription) { in onSubscribe() method in kotlinx.coroutines.reactive.SubscriptionChannel
|
| D | Await.kt | 197 override fun onSubscribe(sub: Subscription) { in awaitOne() method
|
| D | ReactiveFlow.kt | 147 override fun onSubscribe(s: Subscription) { in onSubscribe() method
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/src/ |
| D | Mono.kt | 50 override fun onSubscribe(s: Subscription) { in awaitSingleOrNull() method
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/java/benchmarks/flow/scrabble/optimizations/ |
| D | FlowableSplit.java | 114 public void onSubscribe(Subscription s) { in onSubscribe() method in FlowableSplit.SplitSubscriber
|