| /external/pigweed/pw_rpc/ts/ |
| D | method.ts | 67 onNext: Callback = () => {},
74 onNext,
84 onNext: Callback = () => {},
91 onNext,
107 onNext: Callback = () => {},
114 onNext,
124 onNext: Callback = () => {},
131 onNext,
146 onNext: Callback = () => {},
153 onNext,
[all …]
|
| D | client_test.ts | 304 const onNext = jest.fn(); constant
309 onNext,
315 expect(onNext).toHaveBeenCalledWith(response);
328 const onNext = jest.fn(); constant
331 unaryStub.open(newRequest(5), onNext, onCompleted, onError);
336 expect(onNext).toHaveBeenCalledWith(response);
357 const onNext = jest.fn(); constant
358 const call = unaryStub.invoke(newRequest(), onNext);
368 expect(onNext).not.toHaveBeenCalled();
422 const onNext = jest.fn(); constant
[all …]
|
| D | call.ts | 60 private onNext: Callback; property in Call
71 onNext: Callback,
78 this.onNext = onNext;
118 this.invokeCallback(() => this.onNext(response));
|
| /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/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/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/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/ |
| D | IntegrationTest.kt | 119 sub.onNext(1) in <lambda>()
120 sub.onNext(2) in <lambda>()
175 onNext(1) in <lambda>()
176 onNext(2) in <lambda>()
182 onNext(1) in <lambda>()
187 onNext(0) in <lambda>()
193 onNext(3) in <lambda>()
197 onNext(3) in <lambda>()
204 subscriber.onNext(3) in <lambda>()
|
| D | FlowAsPublisherTest.kt | 38 override fun onNext(t: Int) { in <lambda>() method
68 override fun onNext(t: Int) { in <lambda>() method
96 override fun onNext(t: Int) { in <lambda>() method
133 override fun onNext(t: Int) { in <lambda>() method
|
| D | PublishTest.kt | 27 override fun onNext(t: Int?) { expectUnreached() } in <lambda>() method
50 override fun onNext(t: Int) { in <lambda>() method
75 override fun onNext(t: Int) { expectUnreached() } in <lambda>() method
116 override fun onNext(t: Unit?) { in <lambda>() method
175 override fun onNext(t: String) { in <lambda>() method
211 override fun onNext(t: Int) { in <lambda>() method
|
| D | PublisherCollectTest.kt | 32 subscriber.onNext(lastOutput) in <lambda>()
73 subscriber.onNext(lastOutput) in <lambda>()
115 subscriber.onNext(lastOutput) in <lambda>()
|
| /external/pigweed/pw_rpc/java/main/dev/pigweed/pw_rpc/ |
| D | FutureCall.java | 140 private final Consumer<ResponseT> onNext; field in FutureCall.StreamResponseFuture
144 Consumer<ResponseT> onNext) { in getFactory() argument
145 return (rpcManager, pendingRpc) -> new StreamResponseFuture<>(rpcManager, pendingRpc, onNext); in getFactory()
148 private StreamResponseFuture(Endpoint endpoint, PendingRpc rpc, Consumer<ResponseT> onNext) { in StreamResponseFuture() argument
150 this.onNext = onNext; in StreamResponseFuture()
155 onNext.accept(value); in doHandleNext()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/ |
| D | ObservableAsFlowTest.kt | 20 var onNext = 0 in testCancellation() variable
36 ++onNext in testCancellation()
45 assertEquals(1, onNext) in testCancellation()
60 source.onNext(3) in testImmediateCollection()
62 source.onNext(5) in testImmediateCollection()
85 source.onNext(3) in testOnErrorCancellation()
113 source.onNext(3) in testUnsubscribeOnCollectionException()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/ |
| D | ObservableAsFlowTest.kt | 20 var onNext = 0 in testCancellation() variable
36 ++onNext in testCancellation()
45 assertEquals(1, onNext) in testCancellation()
60 source.onNext(3) in testImmediateCollection()
62 source.onNext(5) in testImmediateCollection()
85 source.onNext(3) in testOnErrorCancellation()
113 source.onNext(3) in testUnsubscribeOnCollectionException()
|
| /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()
|
| /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/ |
| D | GrpclbLoadBalancerTest.java | 412 inOrder.verify(lbRequestObserver).onNext( in loadReporting()
419 lbResponseObserver.onNext(buildInitialResponse(loadReportIntervalMillis)); in loadReporting()
431 lbResponseObserver.onNext(buildLbResponse(backends)); in loadReporting()
568 inOrder.verify(lbRequestObserver).onNext( in loadReporting()
574 lbResponseObserver.onNext(buildInitialResponse(loadReportIntervalMillis)); in loadReporting()
590 lbResponseObserver.onNext(buildLbResponse(backends)); in loadReporting()
631 lbResponseObserver.onNext(buildInitialResponse(1983)); in abundantInitialResponse()
639 lbResponseObserver.onNext(buildInitialResponse(9097)); in abundantInitialResponse()
662 inOrder.verify(lbRequestObserver).onNext( in raceBetweenLoadReportingAndLbStreamClosure()
669 lbResponseObserver.onNext(buildInitialResponse(1983)); in raceBetweenLoadReportingAndLbStreamClosure()
[all …]
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/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
171 override fun onNext(t: String) { in <lambda>() method
207 override fun onNext(t: Int) { in <lambda>() method
|
| /external/pigweed/ts/device/ |
| D | index_test.ts | 113 const onNext = jest.fn(); constant
117 device.rpcs.pw.rpc.test1.TheTestService.SomeServerStreaming(4, onNext, onCompleted, onError);
122 expect(onNext).toBeCalledWith(response1);
123 expect(onNext).toBeCalledWith(response2);
|
| /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) {
|