| /external/dagger2/javatests/dagger/grpc/functional/server/ |
| D | FriendlyBarista.java | 60 public void onCompleted() { in clientStreamingGetCoffee() method
97 public void onCompleted() { in bidiStreamingGetCoffee() method
|
| D | BaristaTest.java | 70 public void onCompleted() { in onCompleted() method in BaristaTest.CoffeeResponseObserver
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/ |
| D | AbstractCoroutineTest.kt | 26 override fun onCompleted(value: String) { in <lambda>() method
66 override fun onCompleted(value: String) { in <lambda>() method
|
| /external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/ |
| D | StreamObserver.java | 78 void onCompleted(); in onCompleted() method
|
| D | ServerCalls.java | 354 public void onCompleted() { in onCompleted() method in ServerCalls.ServerCallStreamObserverImpl
440 public void onCompleted() { in onCompleted() method in ServerCalls.NoopStreamObserver
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/routeguide/ |
| D | RouteGuideServer.java | 197 public void onCompleted() { in recordRoute() method
236 public void onCompleted() { in routeChat() method in RouteGuideServer
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/testing/ |
| D | StreamRecorder.java | 76 public void onCompleted() { in onCompleted() method in StreamRecorder
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/ |
| D | StreamRecorder.java | 71 public void onCompleted() { in onCompleted() method in StreamRecorder
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/ |
| D | RxMaybe.kt | 44 override fun onCompleted(value: T) { in onCompleted() method
|
| D | RxSingle.kt | 43 override fun onCompleted(value: T) { in onCompleted() method
|
| D | RxCompletable.kt | 43 override fun onCompleted(value: Unit) { in onCompleted() method
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/ |
| D | RxMaybe.kt | 58 override fun onCompleted(value: T) { in onCompleted() method
|
| D | RxSingle.kt | 57 override fun onCompleted(value: T) { in onCompleted() method
|
| D | RxCompletable.kt | 57 override fun onCompleted(value: Unit) { in onCompleted() method
|
| /external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/internal/ |
| D | AltsHandshakerStub.java | 107 public void onCompleted() { in onCompleted() method in AltsHandshakerStub.Reader
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/ |
| D | Produce.kt | 146 override fun onCompleted(value: Unit) { in onCompleted() method
|
| /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/ |
| D | LoadWorker.java | 172 public void onCompleted() { in runServer() method in LoadWorker
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/src/ |
| D | Mono.kt | 65 override fun onCompleted(value: T) { in onCompleted() method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | AbstractCoroutine.kt | 82 protected open fun onCompleted(value: T) {} in onCompleted() method
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/exceptions/ |
| D | SuppressionTests.kt | 30 override fun onCompleted(value: String) { in <lambda>() method
|
| /external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
| D | TestServiceImpl.java | 157 public void onCompleted() { in streamingInputCall() method
|
| /external/grpc-grpc-java/alts/src/test/java/io/grpc/alts/internal/ |
| D | AltsHandshakerStubTest.java | 173 public void onCompleted() { in onCompleted() method in AltsHandshakerStubTest.MockWriter
|
| /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/qps/ |
| D | AsyncServer.java | 242 public void onCompleted() { in streamingCall() method in AsyncServer
|
| /external/flatbuffers/grpc/tests/ |
| D | JavaGrpcTest.java | 118 public void onCompleted() { in computeMinMax() method in JavaGrpcTest
|
| /external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/ |
| D | ConcurrencyTest.java | 78 public void onCompleted() { in onCompleted() method in ConcurrencyTest.SignalingResponseObserver
|