/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-rx2/src/ |
D | RxSingle.kt | 63 override fun onCompleted(value: T) { in onCompleted() method
|
D | RxMaybe.kt | 64 override fun onCompleted(value: T) { in onCompleted() method
|
D | RxCompletable.kt | 63 override fun onCompleted(value: Unit) { in onCompleted() method
|
D | RxObservable.kt | 197 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/ |
D | AbstractCoroutine.kt | 82 protected open fun onCompleted(value: T) {} 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 | 69 override fun onCompleted(value: T) { in onCompleted() method
|
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/ |
D | Produce.kt | 135 override fun onCompleted(value: Unit) { in onCompleted() method
|
D | Broadcast.kt | 112 override fun onCompleted(value: Unit) { in <lambda>() 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/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
|
D | NettyFlowControlTest.java | 222 public void onCompleted() { in onCompleted() method in NettyFlowControlTest.TestStreamObserver
|
/external/flatbuffers/grpc/tests/ |
D | JavaGrpcTest.java | 118 public void onCompleted() { in computeMinMax() method in JavaGrpcTest
|