HomeSort by relevance Sort by last modified time
    Searched refs:onCompleted (Results 1 - 25 of 62) sorted by null

1 2 3

  /external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/
StreamObserver.java 40 * #onCompleted()} are called.
75 * exception is thrown by an implementation of {@code onCompleted} no further calls to any method
78 void onCompleted();
StreamObservers.java 53 target.onCompleted();
  /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/
LoadWorker.java 158 onCompleted();
168 onCompleted();
172 public void onCompleted() {
179 responseObserver.onCompleted();
210 onCompleted();
220 onCompleted();
224 public void onCompleted() {
231 responseObserver.onCompleted();
244 responseObserver.onCompleted();
253 responseObserver.onCompleted();
    [all...]
  /external/grpc-grpc-java/services/src/main/java/io/grpc/services/
ChannelzService.java 72 responseObserver.onCompleted();
90 responseObserver.onCompleted();
100 responseObserver.onCompleted();
118 responseObserver.onCompleted();
136 responseObserver.onCompleted();
150 responseObserver.onCompleted();
HealthServiceImpl.java 49 responseObserver.onCompleted();
  /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/manualflowcontrol/
ManualFlowControlServer.java 113 responseObserver.onCompleted();
117 public void onCompleted() {
120 responseObserver.onCompleted();
ManualFlowControlClient.java 86 requestStream.onCompleted();
107 public void onCompleted() {
  /external/grpc-grpc-java/services/src/test/java/io/grpc/protobuf/services/
ProtoReflectionServiceTest.java 186 requestObserver.onCompleted();
214 requestObserver.onCompleted();
220 requestObserver2.onCompleted();
225 requestObserver3.onCompleted();
255 requestObserver.onCompleted();
290 requestObserver.onCompleted();
317 requestObserver.onCompleted();
323 requestObserver2.onCompleted();
328 requestObserver3.onCompleted();
362 requestObserver.onCompleted();
    [all...]
  /external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
MoreInProcessTest.java 86 responseObserver.onCompleted();
97 public void onCompleted() {
122 public void onCompleted() {
145 responseObserver.onCompleted();
156 public void onCompleted() {
181 public void onCompleted() {
214 public void onCompleted() {
240 public void onCompleted() {
  /external/flatbuffers/grpc/tests/
JavaGrpcTest.java 62 responseObserver.onCompleted();
72 responseObserver.onCompleted();
118 public void onCompleted() {
127 responseObserver.onCompleted();
180 public void onCompleted() {
194 monsterStream.onCompleted();
209 public void onCompleted() {
229 monsterStream.onCompleted();
  /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/qps/
AsyncServer.java 216 responseObserver.onCompleted();
229 responseObserver.onCompleted();
242 public void onCompleted() {
244 responseObserver.onCompleted();
258 responseObserver.onCompleted();
271 public void onCompleted() {
274 responseObserver.onCompleted();
293 // responseObserver.onCompleted() for us
321 // responseObserver.onCompleted() for us
354 public void onCompleted() {
    [all...]
  /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/routeguide/
RouteGuideServer.java 131 responseObserver.onCompleted();
158 responseObserver.onCompleted();
197 public void onCompleted() {
202 responseObserver.onCompleted();
236 public void onCompleted() {
237 responseObserver.onCompleted();
  /external/grpc-grpc-java/alts/src/test/java/io/grpc/alts/internal/
AltsHandshakerStubTest.java 161 reader.onCompleted();
173 public void onCompleted() {
174 reader.onCompleted();
  /external/grpc-grpc-java/services/src/test/java/io/grpc/services/
HealthStatusManagerTest.java 70 inOrder.verify(observer, times(1)).onCompleted();
91 verify(observer, never()).onCompleted();
112 verify(observer, never()).onCompleted();
ChannelzServiceTest.java 156 verify(observer).onCompleted();
167 verify(observer).onCompleted();
188 verify(observer).onCompleted();
211 verify(observer).onCompleted();
232 verify(observer).onCompleted();
  /external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/internal/
AltsHandshakerStub.java 79 writer.onCompleted();
107 public void onCompleted() {
  /external/opencensus-java/exporters/trace/ocagent/src/test/java/io/opencensus/exporter/trace/ocagent/
FakeOcAgentTraceServiceGrpcImplTest.java 52 public void onCompleted() {}
64 public void onCompleted() {}
FakeOcAgentTraceServiceGrpcImpl.java 81 public void onCompleted() {}
97 public void onCompleted() {}
  /external/grpc-grpc-java/examples/src/test/java/io/grpc/examples/routeguide/
RouteGuideClientTest.java 123 responseObserver.onCompleted();
184 responseObserver.onCompleted();
283 public void onCompleted() {
285 responseObserver.onCompleted();
338 public void onCompleted() {
384 public void onCompleted() {
420 responseObserverRef.get().onCompleted();
452 public void onCompleted() {
453 responseObserver.onCompleted();
500 public void onCompleted() {
    [all...]
  /external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/
ClientCallsTest.java 276 public void onCompleted() {
303 public void onCompleted() {
349 public void onCompleted() {
396 public void onCompleted() {
397 serverCallObserver.onCompleted();
431 public void onCompleted() {
442 integerStreamObserver.onCompleted();
477 public void onCompleted() {
478 serverCallObserver.onCompleted();
506 requestStream.onCompleted();
    [all...]
  /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/header/
CustomHeaderServer.java 87 responseObserver.onCompleted();
  /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/helloworld/
HelloWorldServer.java 82 responseObserver.onCompleted();
  /external/grpc-grpc-java/benchmarks/src/jmh/java/io/grpc/benchmarks/netty/
AbstractBenchmark.java 409 public void onCompleted() {
417 observer.onCompleted();
444 requestObserverRef.get().onCompleted();
463 public void onCompleted() {
499 obs.onCompleted();
517 public void onCompleted() {
  /external/grpc-grpc-java/examples/example-kotlin/src/main/kotlin/io/grpc/examples/helloworld/
HelloWorldServer.kt 71 responseObserver.onCompleted()
  /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/advanced/
HelloJsonServer.java 98 responseObserver.onCompleted();

Completed in 328 milliseconds

1 2 3