Home
last modified time | relevance | path

Searched defs:onCompleted (Results 1 – 25 of 35) sorted by relevance

12

/external/dagger2/javatests/dagger/grpc/functional/server/
DFriendlyBarista.java60 public void onCompleted() { in clientStreamingGetCoffee() method
97 public void onCompleted() { in bidiStreamingGetCoffee() method
DBaristaTest.java70 public void onCompleted() { in onCompleted() method in BaristaTest.CoffeeResponseObserver
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/
DAbstractCoroutineTest.kt26 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/
DStreamObserver.java78 void onCompleted(); in onCompleted() method
DServerCalls.java354 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/
DRouteGuideServer.java197 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/
DStreamRecorder.java76 public void onCompleted() { in onCompleted() method in StreamRecorder
/external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/
DStreamRecorder.java71 public void onCompleted() { in onCompleted() method in StreamRecorder
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/
DRxSingle.kt63 override fun onCompleted(value: T) { in onCompleted() method
DRxMaybe.kt64 override fun onCompleted(value: T) { in onCompleted() method
DRxCompletable.kt63 override fun onCompleted(value: Unit) { in onCompleted() method
DRxObservable.kt197 override fun onCompleted(value: Unit) { in onCompleted() method
/external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/internal/
DAltsHandshakerStub.java107 public void onCompleted() { in onCompleted() method in AltsHandshakerStub.Reader
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/
DAbstractCoroutine.kt82 protected open fun onCompleted(value: T) {} in onCompleted() method
/external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/
DLoadWorker.java172 public void onCompleted() { in runServer() method in LoadWorker
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/src/
DMono.kt69 override fun onCompleted(value: T) { in onCompleted() method
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/
DProduce.kt135 override fun onCompleted(value: Unit) { in onCompleted() method
DBroadcast.kt112 override fun onCompleted(value: Unit) { in <lambda>() method
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/exceptions/
DSuppressionTests.kt30 override fun onCompleted(value: String) { in <lambda>() method
/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
DTestServiceImpl.java157 public void onCompleted() { in streamingInputCall() method
/external/grpc-grpc-java/alts/src/test/java/io/grpc/alts/internal/
DAltsHandshakerStubTest.java173 public void onCompleted() { in onCompleted() method in AltsHandshakerStubTest.MockWriter
/external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/qps/
DAsyncServer.java242 public void onCompleted() { in streamingCall() method in AsyncServer
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DConcurrencyTest.java78 public void onCompleted() { in onCompleted() method in ConcurrencyTest.SignalingResponseObserver
DNettyFlowControlTest.java222 public void onCompleted() { in onCompleted() method in NettyFlowControlTest.TestStreamObserver
/external/flatbuffers/grpc/tests/
DJavaGrpcTest.java118 public void onCompleted() { in computeMinMax() method in JavaGrpcTest

12