| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/ |
| D | PublishTest.kt | 21 override fun onSubscribe(s: Subscription?) { expect(3) } in <lambda>() method
41 override fun onSubscribe(s: Subscription) { in <lambda>() method
66 override fun onSubscribe(s: Subscription) { in <lambda>() method
106 override fun onSubscribe(s: Subscription) { in <lambda>() method
143 override fun onSubscribe(s: Subscription) { in <lambda>() method
|
| D | FlowAsPublisherTest.kt | 32 override fun onSubscribe(s: Subscription?) { in <lambda>() method
62 override fun onSubscribe(s: Subscription?) { in <lambda>() method
89 override fun onSubscribe(s: Subscription) { in <lambda>() method
126 override fun onSubscribe(s: Subscription) { in <lambda>() method
|
| D | IterableFlowTckTest.kt | 44 override fun onSubscribe(s: Subscription) { in createFailedPublisher() method
45 subscriber.onSubscribe(s) in createFailedPublisher()
63 override fun onSubscribe(s: Subscription) { in testStackOverflowTrampoline() method
98 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 | 21 override fun onSubscribe(s: JFlow.Subscription?) { expect(3) } in <lambda>() method
41 override fun onSubscribe(s: JFlow.Subscription) { in <lambda>() method
66 override fun onSubscribe(s: JFlow.Subscription) { in <lambda>() method
106 override fun onSubscribe(s: JFlow.Subscription) { in <lambda>() method
143 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-rx2/src/ |
| D | RxAwait.kt | 26 override fun onSubscribe(d: Disposable) { cont.disposeOnCancellation(d) } in <lambda>() method
57 override fun onSubscribe(d: Disposable) { cont.disposeOnCancellation(d) } in await() method
76 override fun onSubscribe(d: Disposable) { cont.disposeOnCancellation(d) } in await() method
173 override fun onSubscribe(sub: Disposable) { in toString() method
|
| D | RxChannel.kt | 77 override fun onSubscribe(sub: Disposable) { in consumeEach() method in kotlinx.coroutines.rx2.SubscriptionChannel
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/ |
| D | RxAwait.kt | 26 override fun onSubscribe(d: Disposable) { cont.disposeOnCancellation(d) } in <lambda>() method
57 override fun onSubscribe(d: Disposable) { cont.disposeOnCancellation(d) } in await() method
76 override fun onSubscribe(d: Disposable) { cont.disposeOnCancellation(d) } in await() method
173 override fun onSubscribe(sub: Disposable) { in toString() method
|
| D | RxChannel.kt | 67 override fun onSubscribe(sub: Disposable) { in collect() method in kotlinx.coroutines.rx3.SubscriptionChannel
|
| D | RxConvert.kt | 83 … override fun onSubscribe(d: Disposable) { if (!disposableRef.compareAndSet(null, d)) d.dispose() } 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
|
| D | CompletableTest.kt | 140 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
|
| /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 | ReactiveFlow.kt | 142 override fun onSubscribe(s: Subscription) { in onSubscribe() method
177 subscriber.onSubscribe(FlowSubscription(flow, subscriber, context)) in subscribe()
|
| D | Channel.kt | 91 override fun onSubscribe(s: Subscription) { in consumeEach() method in kotlinx.coroutines.reactive.SubscriptionChannel
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/src/ |
| D | ReactorFlow.kt | 39 subscriber.onSubscribe(FlowSubscription(source, subscriber, context)) in asFlux()
|
| D | Flux.kt | 70 …subscriber.onSubscribe(coroutine) // do it first (before starting coroutine), to avoid unnecessary… in flux()
|
| /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
118 downstream.onSubscribe(this); in onSubscribe()
|
| D | FlowableCharSequence.java | 24 s.onSubscribe(new CharSequenceSubscription(s, string)); in subscribeActual()
|