| /external/grpc-grpc-java/examples/src/test/java/io/grpc/examples/routeguide/ |
| D | RouteGuideServerTest.java | 141 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 …]
|
| D | RouteGuideClientTest.java | 122 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/dagger2/javatests/dagger/grpc/functional/server/ |
| D | FriendlyBarista.java | 40 responseObserver.onNext(response("Here you go!", request.getTypeList())); in unaryGetCoffee()
52 public void onNext(CoffeeRequest value) { in clientStreamingGetCoffee() method
62 responseObserver.onNext(response.build()); in clientStreamingGetCoffee()
72 responseObserver.onNext(response("Here's a " + type, singletonList(type))); in serverStreamingGetCoffee()
85 public void onNext(CoffeeRequest value) { in bidiStreamingGetCoffee() method
86 responseObserver.onNext(response("Enjoy!", value.getTypeList())); in bidiStreamingGetCoffee()
88 responseObserver.onNext(CoffeeResponse.newBuilder().setMessage("We're done.").build()); in bidiStreamingGetCoffee()
|
| D | BaristaTest.java | 60 public void onNext(CoffeeResponse value) { in onNext() method in BaristaTest.CoffeeResponseObserver
116 requestObserver.onNext(request(POUR_OVER, LATTE)); in testClientStreamingGetCoffee()
117 requestObserver.onNext(request(AMERICANO)); in testClientStreamingGetCoffee()
118 requestObserver.onNext(request(DRIP, ESPRESSO)); in testClientStreamingGetCoffee()
136 requestObserver.onNext(request(POUR_OVER, LATTE)); in testBidiStreamingGetCoffee()
137 requestObserver.onNext(request(AMERICANO)); in testBidiStreamingGetCoffee()
138 requestObserver.onNext(request(DRIP, ESPRESSO)); in testBidiStreamingGetCoffee()
|
| /external/grpc-grpc-java/services/src/test/java/io/grpc/protobuf/services/ |
| D | ProtoReflectionServiceTest.java | 185 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/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/guide/ |
| D | example-reactive-basic-06.kt | 12 subject.onNext("one") in main()
13 subject.onNext("two") // updates the state of BehaviorSubject, "one" value is lost in main()
16 subject.onNext("three") in main()
17 subject.onNext("four") in main()
|
| D | example-reactive-basic-07.kt | 14 subject.onNext("one") in <lambda>()
15 subject.onNext("two") in <lambda>()
20 subject.onNext("three") in <lambda>()
21 subject.onNext("four") in <lambda>()
|
| D | example-reactive-basic-08.kt | 15 subject.onNext("one") in <lambda>()
16 subject.onNext("two") in <lambda>()
21 subject.onNext("three") in <lambda>()
22 subject.onNext("four") in <lambda>()
|
| /external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/ |
| D | MoreInProcessTest.java | 85 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/ |
| D | LoadWorker.java | 130 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());
|
| /external/flatbuffers/grpc/tests/ |
| D | JavaGrpcTest.java | 61 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/ |
| D | ChannelzService.java | 71 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/ |
| D | FakeOcAgentTraceServiceGrpcImplTest.java | 44 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()
|
| D | FakeOcAgentTraceServiceGrpcImpl.java | 65 public void onNext(CurrentLibraryConfig value) {
71 updatedConfigObserver.onNext(updatedLibraryConfig);
87 public void onNext(ExportTraceServiceRequest value) {
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/ |
| D | PublishTest.kt | 23 override fun onNext(t: Int?) { expectUnreached() } in <lambda>() method
46 override fun onNext(t: Int) { in <lambda>() method
71 override fun onNext(t: Int) { expectUnreached() } in <lambda>() method
112 override fun onNext(t: Unit?) { in <lambda>() method
149 override fun onNext(t: String) { in <lambda>() method
|
| D | PublisherAsFlowTest.kt | 15 var onNext = 0 in <lambda>() variable
31 ++onNext in <lambda>()
40 assertEquals(1, onNext) in <lambda>()
|
| D | FlowAsPublisherTest.kt | 37 override fun onNext(t: Int) { in testErrorOnCancellationIsReported() method
68 override fun onNext(t: Int) { in testCancellationIsNotReported() method
|
| /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/ |
| D | GrpclbLoadBalancerTest.java | 413 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/ |
| D | RouteGuideServer.java | 130 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()
|
| /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/qps/ |
| D | AsyncServer.java | 215 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) {
|
| /external/grpc-grpc-java/benchmarks/src/test/java/io/grpc/benchmarks/driver/ |
| D | LoadWorkerTest.java | 187 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/ |
| D | ChannelzServiceTest.java | 155 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/benchmarks/src/jmh/java/io/grpc/benchmarks/netty/ |
| D | AbstractBenchmark.java | 399 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/ |
| D | TestServiceImpl.java | 79 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/alts/src/test/java/io/grpc/alts/internal/ |
| D | AltsHandshakerStubTest.java | 146 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()
|