| /external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/ |
| D | StreamObserver.java | 52 void onNext(V value); in onNext() method
|
| D | ServerCalls.java | 333 public void onNext(RespT response) { in onNext() method in ServerCalls.ServerCallStreamObserverImpl
432 public void onNext(V value) { in onNext() method in ServerCalls.NoopStreamObserver
|
| D | ClientCalls.java | 334 public void onNext(T value) { in onNext() method in ClientCalls.CallToStreamObserverAdapter
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/testing/ |
| D | StreamRecorder.java | 59 public void onNext(T value) { in onNext() method in StreamRecorder
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/ |
| D | StreamRecorder.java | 54 public void onNext(T value) { in onNext() method in StreamRecorder
|
| /external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/internal/ |
| D | AltsHandshakerStub.java | 85 public void onNext(HandshakerResp resp) { in onNext() method in AltsHandshakerStub.Reader
|
| /external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
| D | TestServiceImpl.java | 152 public void onNext(StreamingInputCallRequest message) { in streamingInputCall() method
|
| D | Http2Client.java | 289 public void onNext(SimpleResponse value) { in onNext() method in Http2Client.Tester.RstStreamObserver
|
| /external/grpc-grpc-java/alts/src/test/java/io/grpc/alts/internal/ |
| D | AltsHandshakerStubTest.java | 151 public void onNext(final HandshakerReq req) { in onNext() method in AltsHandshakerStubTest.MockWriter
|
| /external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/ |
| D | ConcurrencyTest.java | 90 public void onNext(StreamingOutputCallResponse response) { in onNext() method in ConcurrencyTest.SignalingResponseObserver
|
| D | NettyFlowControlTest.java | 208 public void onNext(StreamingOutputCallResponse value) { in onNext() method in NettyFlowControlTest.TestStreamObserver
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/routeguide/ |
| D | RouteGuideServer.java | 178 public void onNext(Point point) { in recordRoute() method
|
| /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/ |
| D | LoadClient.java | 468 public void onNext(ByteBuf value) { in run() method
|
| /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/qps/ |
| D | AsyncClient.java | 231 public void onNext(SimpleResponse value) { in onNext() method in AsyncClient.ThisIsAHackStreamObserver
|
| /external/grpc-grpc-java/services/src/test/java/io/grpc/protobuf/services/ |
| D | ProtoReflectionServiceTest.java | 601 public void onNext(ServerReflectionResponse value) { in onNext() method in ProtoReflectionServiceTest.FlowControlClientResponseObserver
|
| /external/grpc-grpc-java/services/src/main/java/io/grpc/protobuf/services/ |
| D | ProtoReflectionService.java | 166 public void onNext(ServerReflectionRequest request) { in onNext() method in ProtoReflectionService.ProtoReflectionStreamObserver
|
| /external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/ |
| D | GrpclbState.java | 489 @Override public void onNext(final LoadBalanceResponse response) { in onNext() method in GrpclbState.LbStream
|