| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/ |
| D | PublishTest.kt | 23 override fun onComplete() { expect(6) } in <lambda>() method
49 override fun onComplete() { expect(8) } in <lambda>() method
71 override fun onComplete() { expectUnreached() } in <lambda>() method
102 override fun onComplete() { in <lambda>() method
139 override fun onComplete() { in <lambda>() method
|
| D | FlowAsPublisherTest.kt | 28 override fun onComplete() { in <lambda>() method
58 override fun onComplete() { in <lambda>() method
101 override fun onComplete() { in <lambda>() method
138 override fun onComplete() { in <lambda>() method
|
| D | IterableFlowTckTest.kt | 78 override fun onComplete() { in testStackOverflowTrampoline() method
113 override fun onComplete() { in testConcurrentRequest() method
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/test/ |
| D | PublishTest.kt | 23 override fun onComplete() { expect(6) } in <lambda>() method
49 override fun onComplete() { expect(8) } in <lambda>() method
71 override fun onComplete() { expectUnreached() } in <lambda>() method
102 override fun onComplete() { in <lambda>() method
139 override fun onComplete() { in <lambda>() method
|
| D | FlowAsPublisherTest.kt | 28 override fun onComplete() { in testErrorOnCancellationIsReported() method
58 override fun onComplete() { in testCancellationIsNotReported() method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/js/src/internal/ |
| D | LinkedList.kt | 100 override fun onComplete() = queue.addLast(node) in onComplete() method in kotlinx.coroutines.internal.AddLastDesc
112 override fun onComplete() { queue.removeFirstOrNull() } in onComplete() method in kotlinx.coroutines.internal.RemoveFirstDesc
120 protected abstract fun onComplete() in finishPrepare() method
137 actual final override fun complete(op: AtomicOp<*>, failure: Any?) = onComplete() in complete()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/native/src/internal/ |
| D | LinkedList.kt | 100 override fun onComplete() = queue.addLast(node) in onComplete() method in kotlinx.coroutines.internal.AddLastDesc
112 override fun onComplete() { queue.removeFirstOrNull() } in onComplete() method in kotlinx.coroutines.internal.RemoveFirstDesc
120 protected abstract fun onComplete() in finishPrepare() method
137 actual final override fun complete(op: AtomicOp<*>, failure: Any?) = onComplete() in complete()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | PartialForwardingServerCallListener.java | 44 public void onComplete() { in onComplete() method in PartialForwardingServerCallListener
45 delegate().onComplete(); in onComplete()
|
| D | Contexts.java | 103 public void onComplete() { in onComplete() method in Contexts.ContextualizedServerCallListener
106 super.onComplete(); in onComplete()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/ |
| D | RxConvert.kt | 82 override fun onComplete() { close() } in <lambda>() method
116 emitter.onComplete() in asObservable()
124 emitter.onComplete() in asObservable()
|
| D | RxAwait.kt | 27 override fun onComplete() { cont.resume(Unit) } in <lambda>() method
58 override fun onComplete() { cont.resume(default) } in await() method
201 override fun onComplete() { in toString() method
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/ |
| D | RxConvert.kt | 82 override fun onComplete() { close() } in <lambda>() method
116 emitter.onComplete() in asObservable()
124 emitter.onComplete() in asObservable()
|
| D | RxAwait.kt | 27 override fun onComplete() { cont.resume(Unit) } in <lambda>() method
58 override fun onComplete() { cont.resume(default) } in await() method
201 override fun onComplete() { in toString() method
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/ |
| D | FlowAsFlowableTest.kt | 38 override fun onComplete() { in <lambda>() method
75 override fun onComplete() { in <lambda>() method
|
| D | FlowAsObservableTest.kt | 164 override fun onComplete() { in <lambda>() method
197 override fun onComplete() { in <lambda>() method
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/ |
| D | FlowAsFlowableTest.kt | 38 override fun onComplete() { in <lambda>() method
75 override fun onComplete() { in <lambda>() method
|
| D | FlowAsObservableTest.kt | 164 override fun onComplete() { in <lambda>() method
197 override fun onComplete() { in <lambda>() method
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/ |
| D | ContextsTest.java | 76 @Override public void onComplete() { in interceptCall_basic()
102 wrapped.onComplete(); in interceptCall_basic()
141 @Override public void onComplete() { in interceptCall_restoresIfListenerThrows()
174 wrapped.onComplete(); in interceptCall_restoresIfListenerThrows()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/ |
| D | ReactiveFlow.kt | 134 override fun onComplete() { in onComplete() method
199 subscriber.onComplete() in flowProcessing()
203 subscriber.onComplete() in flowProcessing()
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/java/benchmarks/flow/scrabble/optimizations/ |
| D | FlowableCharSequence.java | 80 a.onComplete(); in fastPath()
106 a.onComplete(); in slowPath()
|
| D | FlowableSplit.java | 179 public void onComplete() { in onComplete() method in FlowableSplit.SplitSubscriber
238 a.onComplete(); in drain()
308 a.onComplete(); in drain()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/test/ |
| D | FlowAsFluxTest.kt | 97 override fun onComplete() { in <lambda>() method
134 override fun onComplete() { in <lambda>() method
|
| /external/webrtc/sdk/android/api/org/webrtc/ |
| D | StatsObserver.java | 16 @CalledByNative public void onComplete(StatsReport[] reports); in onComplete() method
|
| /external/grpc-grpc-java/android-interop-testing/app/src/main/java/io/grpc/android/integrationtest/ |
| D | InteropTask.java | 35 void onComplete(String result); in onComplete() method
146 listener.onComplete(result); in onPostExecute()
|
| /external/dagger2/java/dagger/grpc/server/ |
| D | ProxyServerCallHandler.java | 141 public void onComplete() { in onComplete() method in ProxyServerCallHandler.ServerCallListenerAdapter
142 delegate.onComplete(); in onComplete()
|