Home
last modified time | relevance | path

Searched refs:onNext (Results 1 – 25 of 59) sorted by relevance

123

/external/grpc-grpc-java/examples/src/test/java/io/grpc/examples/routeguide/
DRouteGuideServerTest.java141 public void onNext(Feature value) { in listFeatures()
188 requestObserver.onNext(p1); in recordRoute()
189 requestObserver.onNext(p2); in recordRoute()
190 requestObserver.onNext(p3); in recordRoute()
191 requestObserver.onNext(p4); in recordRoute()
193 verify(responseObserver, never()).onNext(any(RouteSummary.class)); in recordRoute()
198 verify(responseObserver, timeout(100)).onNext(routeSummaryCaptor.capture()); in recordRoute()
224 verify(responseObserver, never()).onNext(any(RouteNote.class)); in routeChat()
226 requestObserver.onNext(n1); in routeChat()
227 verify(responseObserver, never()).onNext(any(RouteNote.class)); in routeChat()
[all …]
DRouteGuideClientTest.java122 responseObserver.onNext(responseFeature); in getFeature()
180 responseObserver.onNext(responseFeature1); in listFeatures()
181 responseObserver.onNext(responseFeature2); in listFeatures()
219 responseObserver.onNext(responseFeature1); in listFeatures_error()
274 public void onNext(Point value) { in recordRoute()
284 responseObserver.onNext(fakeResponse); in recordRoute()
330 public void onNext(Point value) { in recordRoute_serverError()
374 public void onNext(RouteNote value) { in routeChat_simpleResponse()
414 responseObserverRef.get().onNext(fakeResponse1); in routeChat_simpleResponse()
416 responseObserverRef.get().onNext(fakeResponse2); in routeChat_simpleResponse()
[all …]
/external/grpc-grpc-java/services/src/test/java/io/grpc/protobuf/services/
DProtoReflectionServiceTest.java185 requestObserver.onNext(request); in fileByFilename()
213 requestObserver.onNext(request); in fileByFilenameConsistentForMutableServices()
219 requestObserver2.onNext(request); in fileByFilenameConsistentForMutableServices()
224 requestObserver3.onNext(request); in fileByFilenameConsistentForMutableServices()
254 requestObserver.onNext(request); in fileContainingSymbol()
289 requestObserver.onNext(request); in fileContainingNestedSymbol()
316 requestObserver.onNext(request); in fileContainingSymbolForMutableServices()
322 requestObserver2.onNext(request); in fileContainingSymbolForMutableServices()
327 requestObserver3.onNext(request); in fileContainingSymbolForMutableServices()
361 requestObserver.onNext(request); in fileContainingExtension()
[all …]
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DMoreInProcessTest.java85 responseObserver.onNext(fakeResponse); in asyncClientStreaming_serverResponsePriorToRequest()
89 public void onNext(StreamingInputCallRequest value) { in asyncClientStreaming_serverResponsePriorToRequest()
111 public void onNext(StreamingInputCallResponse response) { in asyncClientStreaming_serverResponsePriorToRequest()
148 public void onNext(StreamingInputCallRequest value) { in asyncClientStreaming_serverErrorPriorToRequest()
170 public void onNext(StreamingInputCallResponse response) { in asyncClientStreaming_serverErrorPriorToRequest()
204 public void onNext(StreamingInputCallRequest value) { in asyncClientStreaming_erroneousServiceImpl()
229 public void onNext(StreamingInputCallResponse response) { in asyncClientStreaming_erroneousServiceImpl()
247 .onNext(StreamingInputCallRequest.getDefaultInstance()); in asyncClientStreaming_erroneousServiceImpl()
/external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/
DLoadWorker.java130 public void onNext(ServerArgs value) { in runServer()
141 responseObserver.onNext(Control.ServerStatus.newBuilder() in runServer()
146 responseObserver.onNext(Control.ServerStatus.newBuilder() in runServer()
190 public void onNext(ClientArgs value) {
196 responseObserver.onNext(Control.ClientStatus.newBuilder().build());
198 responseObserver.onNext(Control.ClientStatus.newBuilder()
240 responseObserver.onNext(
252 responseObserver.onNext(Control.Void.getDefaultInstance());
DLoadClient.java344 public void onNext(Messages.SimpleResponse value) { in run()
388 public void onNext(Messages.SimpleResponse value) { in run()
395 requestObserver.get().onNext(simpleRequest); in run()
412 requestObserver.get().onNext(simpleRequest); in run()
468 public void onNext(ByteBuf value) { in run() method
/external/flatbuffers/grpc/tests/
DJavaGrpcTest.java61 responseObserver.onNext(stat); in store()
70 responseObserver.onNext(monster); in retrieve()
95 public void onNext(Monster monster) { in computeMinMax()
121 responseObserver.onNext(maxHpStat); in computeMinMax()
125 responseObserver.onNext(minHpStat); in computeMinMax()
184 public void onNext(Stat stat) {
192 monsterStream.onNext(monster);
213 public void onNext(Stat stat) {
227 monsterStream.onNext(monster);
/external/grpc-grpc-java/services/src/main/java/io/grpc/services/
DChannelzService.java71 responseObserver.onNext(ChannelzProtoUtil.toGetTopChannelResponse(rootChannels)); in getTopChannels()
85 responseObserver.onNext( in getChannel()
99 responseObserver.onNext(ChannelzProtoUtil.toGetServersResponse(servers)); in getServers()
113 responseObserver.onNext( in getSubchannel()
131 responseObserver.onNext( in getSocket()
149 responseObserver.onNext(ChannelzProtoUtil.toGetServerSocketsResponse(serverSockets)); in getServerSockets()
/external/opencensus-java/exporters/trace/ocagent/src/test/java/io/opencensus/exporter/trace/ocagent/
DFakeOcAgentTraceServiceGrpcImplTest.java44 public void onNext(UpdatedLibraryConfig value) {
58 public void onNext(ExportTraceServiceResponse value) {}
81 exportRequestObserver.onNext(request); in export()
91 currentConfigObsever.onNext(currentLibraryConfig); in config()
104 currentConfigObsever.onNext(currentLibraryConfig); in config_WithNeverSampler()
DFakeOcAgentTraceServiceGrpcImpl.java65 public void onNext(CurrentLibraryConfig value) {
71 updatedConfigObserver.onNext(updatedLibraryConfig);
87 public void onNext(ExportTraceServiceRequest value) {
/external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
DGrpclbLoadBalancerTest.java413 inOrder.verify(lbRequestObserver).onNext( in loadReporting()
420 lbResponseObserver.onNext(buildInitialResponse(loadReportIntervalMillis)); in loadReporting()
432 lbResponseObserver.onNext(buildLbResponse(backends)); in loadReporting()
569 inOrder.verify(lbRequestObserver).onNext( in loadReporting()
575 lbResponseObserver.onNext(buildInitialResponse(loadReportIntervalMillis)); in loadReporting()
591 lbResponseObserver.onNext(buildLbResponse(backends)); in loadReporting()
632 lbResponseObserver.onNext(buildInitialResponse(1983)); in abundantInitialResponse()
640 lbResponseObserver.onNext(buildInitialResponse(9097)); in abundantInitialResponse()
663 inOrder.verify(lbRequestObserver).onNext( in raceBetweenLoadReportingAndLbStreamClosure()
670 lbResponseObserver.onNext(buildInitialResponse(1983)); in raceBetweenLoadReportingAndLbStreamClosure()
[all …]
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/routeguide/
DRouteGuideServer.java130 responseObserver.onNext(checkFeature(request)); in getFeature()
155 responseObserver.onNext(feature); in listFeatures()
178 public void onNext(Point point) { in recordRoute() method
199 responseObserver.onNext(RouteSummary.newBuilder().setPointCount(pointCount) in recordRoute()
218 public void onNext(RouteNote note) { in routeChat()
223 responseObserver.onNext(prevNote); in routeChat()
DRouteGuideClient.java139 public void onNext(RouteSummary summary) { in recordRoute()
172 requestObserver.onNext(point); in recordRoute()
205 public void onNext(RouteNote note) { in routeChat()
237 requestObserver.onNext(request); in routeChat()
/external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/qps/
DAsyncServer.java215 responseObserver.onNext(Utils.makeResponse(request)); in unaryCall()
227 public void onNext(Messages.SimpleRequest value) { in streamingCall()
232 responseObserver.onNext(Utils.makeResponse(value)); in streamingCall()
256 public void onNext(Messages.SimpleRequest value) {
273 responseObserver.onNext(Utils.makeResponse(lastSeen));
344 public void onNext(final Messages.SimpleRequest request) {
DAsyncClient.java161 public void onNext(SimpleResponse value) { in doUnaryCalls()
202 requestObserver.onNext(request); in doStreamingCalls()
231 public void onNext(SimpleResponse value) { in onNext() method in AsyncClient.ThisIsAHackStreamObserver
238 requestObserver.onNext(request); in onNext()
/external/grpc-grpc-java/benchmarks/src/jmh/java/io/grpc/benchmarks/netty/
DAbstractBenchmark.java399 public void onNext(ByteBuf value) { in startUnaryCalls()
441 public void onNext(ByteBuf value) { in startStreamingCalls()
448 requestObserverRef.get().onNext(request.slice()); in startStreamingCalls()
468 requestObserver.onNext(request.slice()); in startStreamingCalls()
469 requestObserver.onNext(request.slice()); in startStreamingCalls()
495 public void onNext(ByteBuf value) { in startFlowControlledStreamingCalls()
525 requestObserver.onNext(request.slice()); in startFlowControlledStreamingCalls()
/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
DTestServiceImpl.java79 responseObserver.onNext(EmptyProtos.Empty.getDefaultInstance()); in emptyCall()
126 responseObserver.onNext(responseBuilder.build()); in unaryCall()
152 public void onNext(StreamingInputCallRequest message) { in streamingInputCall() method
158 responseObserver.onNext(StreamingInputCallResponse.newBuilder() in streamingInputCall()
180 public void onNext(StreamingOutputCallRequest request) { in fullDuplexCall()
217 public void onNext(StreamingOutputCallRequest request) {
337 responseStream.onNext(chunk.toResponse());
/external/grpc-grpc-java/benchmarks/src/test/java/io/grpc/benchmarks/driver/
DLoadWorkerTest.java187 clientObserver.onNext(MARK); in assertWorkOccurred()
211 public void onNext(Control.ClientStatus value) {
228 clientObserver.onNext(clientArgs);
241 public void onNext(Control.ServerStatus value) {
255 serverObserver.onNext(serverArgs);
/external/grpc-grpc-java/services/src/test/java/io/grpc/services/
DChannelzServiceTest.java155 verify(observer).onNext(responseCaptor.capture()); in getTopChannelHelper()
166 verify(observer).onNext(response.capture()); in getChannelHelper()
187 verify(observer).onNext(response.capture()); in getSubchannelHelper()
210 verify(observer).onNext(responseCaptor.capture()); in getServersHelper()
231 verify(observer).onNext(response.capture()); in getSocketHelper()
/external/grpc-grpc-java/alts/src/test/java/io/grpc/alts/internal/
DAltsHandshakerStubTest.java146 reader.onNext(HandshakerResp.newBuilder().build()); in sendUnexpectedResponse()
151 public void onNext(final HandshakerReq req) { in onNext() method in AltsHandshakerStubTest.MockWriter
155 reader.onNext(resp.setOutFrames(req.getNext().getInBytes()).build()); in onNext()
/external/grpc-grpc-java/services/src/main/java/io/grpc/protobuf/services/
DProtoReflectionService.java166 public void onNext(ServerReflectionRequest request) { in onNext() method in ProtoReflectionService.ProtoReflectionStreamObserver
223 serverCallStreamObserver.onNext(createServerReflectionResponse(request, fd)); in getFileByName()
233 serverCallStreamObserver.onNext(createServerReflectionResponse(request, fd)); in getFileContainingSymbol()
246 serverCallStreamObserver.onNext(createServerReflectionResponse(request, fd)); in getFileByExtension()
260 serverCallStreamObserver.onNext( in getAllExtensions()
276 serverCallStreamObserver.onNext( in listServices()
295 serverCallStreamObserver.onNext(response); in sendErrorResponse()
/external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/
DClientCallsTest.java266 public void onNext(String value) { in disablingInboundAutoFlowControlSuppressesRequestsForMoreMessages()
295 public void onNext(String value) { in callStreamObserverPropagatesFlowControlRequestsToCall()
341 public void onNext(String value) { in canCaptureInboundFlowControlForServerStreamingObserver()
388 serverCallObserver.onNext(iteration); in inprocessTransportInboundFlowControl()
420 public void onNext(Integer value) { in inprocessTransportInboundFlowControl()
467 public void onNext(Integer value) { in inprocessTransportOutboundFlowControl()
502 requestStream.onNext(iteration); in inprocessTransportOutboundFlowControl()
514 public void onNext(Integer value) { in inprocessTransportOutboundFlowControl()
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/manualflowcontrol/
DManualFlowControlServer.java72 public void onNext(HelloRequest request) { in main()
86 responseObserver.onNext(reply); in main()
DManualFlowControlClient.java83 requestStream.onNext(request); in main()
94 public void onNext(HelloReply value) { in main()
/external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/internal/
DAltsHandshakerStub.java62 writer.onNext(req); in send()
85 public void onNext(HandshakerResp resp) { in onNext() method in AltsHandshakerStub.Reader

123