Home
last modified time | relevance | path

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

/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
DClientCalls.java344 public void onCompleted() { in onCompleted() method in ClientCalls.CallToStreamObserverAdapter
/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/grpc-grpc-java/alts/src/main/java/io/grpc/alts/internal/
DAltsHandshakerStub.java107 public void onCompleted() { in onCompleted() method in AltsHandshakerStub.Reader
/external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/
DLoadWorker.java172 public void onCompleted() { in runServer() method in LoadWorker
DLoadClient.java480 public void onCompleted() { in run() method
/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
DTestServiceImpl.java157 public void onCompleted() { in streamingInputCall() method
DHttp2Client.java300 public void onCompleted() { in onCompleted() method in Http2Client.Tester.RstStreamObserver
/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
DAsyncClient.java254 public void onCompleted() { in onCompleted() method in AsyncClient.ThisIsAHackStreamObserver
/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
/external/grpc-grpc-java/services/src/test/java/io/grpc/protobuf/services/
DProtoReflectionServiceTest.java611 public void onCompleted() { in onCompleted() method in ProtoReflectionServiceTest.FlowControlClientResponseObserver
/external/grpc-grpc-java/services/src/main/java/io/grpc/protobuf/services/
DProtoReflectionService.java206 public void onCompleted() { in onCompleted() method in ProtoReflectionService.ProtoReflectionStreamObserver
/external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/
DGrpclbState.java508 @Override public void onCompleted() { in onCompleted() method in GrpclbState.LbStream