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

1 2 3

  /external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/
StreamObserver.java 42 * <p>Unary calls must invoke onNext at most once. Clients may invoke onNext at most once for
43 * server streaming calls, but may receive many onNext callbacks. Servers may invoke onNext at
44 * most once for client streaming calls, but may receive many onNext callbacks.
52 void onNext(V value);
StreamObservers.java 50 target.onNext(source.next());
  /external/grpc-grpc-java/examples/src/test/java/io/grpc/examples/routeguide/
RouteGuideServerTest.java 141 public void onNext(Feature value) {
188 requestObserver.onNext(p1);
189 requestObserver.onNext(p2);
190 requestObserver.onNext(p3);
191 requestObserver.onNext(p4);
193 verify(responseObserver, never()).onNext(any(RouteSummary.class));
198 verify(responseObserver, timeout(100)).onNext(routeSummaryCaptor.capture());
224 verify(responseObserver, never()).onNext(any(RouteNote.class));
226 requestObserver.onNext(n1);
227 verify(responseObserver, never()).onNext(any(RouteNote.class))
    [all...]
RouteGuideClientTest.java 122 responseObserver.onNext(responseFeature);
180 responseObserver.onNext(responseFeature1);
181 responseObserver.onNext(responseFeature2);
219 responseObserver.onNext(responseFeature1);
274 public void onNext(Point value) {
284 responseObserver.onNext(fakeResponse);
330 public void onNext(Point value) {
374 public void onNext(RouteNote value) {
414 responseObserverRef.get().onNext(fakeResponse1);
416 responseObserverRef.get().onNext(fakeResponse2)
    [all...]
  /external/opencensus-java/exporters/trace/ocagent/src/test/java/io/opencensus/exporter/trace/ocagent/
FakeOcAgentTraceServiceGrpcImplTest.java 44 public void onNext(UpdatedLibraryConfig value) {
58 public void onNext(ExportTraceServiceResponse value) {}
81 exportRequestObserver.onNext(request);
91 currentConfigObsever.onNext(currentLibraryConfig);
104 currentConfigObsever.onNext(currentLibraryConfig);
FakeOcAgentTraceServiceGrpcImpl.java 65 public void onNext(CurrentLibraryConfig value) {
71 updatedConfigObserver.onNext(updatedLibraryConfig);
87 public void onNext(ExportTraceServiceRequest value) {
  /external/grpc-grpc-java/services/src/main/java/io/grpc/services/
ChannelzService.java 71 responseObserver.onNext(ChannelzProtoUtil.toGetTopChannelResponse(rootChannels));
85 responseObserver.onNext(
99 responseObserver.onNext(ChannelzProtoUtil.toGetServersResponse(servers));
113 responseObserver.onNext(
131 responseObserver.onNext(
149 responseObserver.onNext(ChannelzProtoUtil.toGetServerSocketsResponse(serverSockets));
HealthServiceImpl.java 48 responseObserver.onNext(response);
  /external/grpc-grpc-java/services/src/test/java/io/grpc/protobuf/services/
ProtoReflectionServiceTest.java 185 requestObserver.onNext(request);
213 requestObserver.onNext(request);
219 requestObserver2.onNext(request);
224 requestObserver3.onNext(request);
254 requestObserver.onNext(request);
289 requestObserver.onNext(request);
316 requestObserver.onNext(request);
322 requestObserver2.onNext(request);
327 requestObserver3.onNext(request);
361 requestObserver.onNext(request)
    [all...]
  /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/
LoadWorker.java 130 public void onNext(ServerArgs value) {
141 responseObserver.onNext(Control.ServerStatus.newBuilder()
146 responseObserver.onNext(Control.ServerStatus.newBuilder()
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/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
MoreInProcessTest.java 85 responseObserver.onNext(fakeResponse);
89 public void onNext(StreamingInputCallRequest value) {
111 public void onNext(StreamingInputCallResponse response) {
148 public void onNext(StreamingInputCallRequest value) {
170 public void onNext(StreamingInputCallResponse response) {
204 public void onNext(StreamingInputCallRequest value) {
229 public void onNext(StreamingInputCallResponse response) {
247 .onNext(StreamingInputCallRequest.getDefaultInstance());
  /external/flatbuffers/grpc/tests/
JavaGrpcTest.java 61 responseObserver.onNext(stat);
70 responseObserver.onNext(monster);
95 public void onNext(Monster monster) {
121 responseObserver.onNext(maxHpStat);
125 responseObserver.onNext(minHpStat);
184 public void onNext(Stat stat) {
192 monsterStream.onNext(monster);
213 public void onNext(Stat stat) {
227 monsterStream.onNext(monster);
  /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/manualflowcontrol/
ManualFlowControlClient.java 83 requestStream.onNext(request);
94 public void onNext(HelloReply value) {
ManualFlowControlServer.java 44 // Guard against spurious onReady() calls caused by a race between onNext() and onReady(). If the transport
45 // toggles isReady() from false to true while onNext() is executing, but before onNext() checks isReady(),
46 // request(1) would be called twice - once by onNext() and once by the onReady() scheduled during onNext()'s
54 // onNext(), onError(), and onComplete() handlers. Blocking the onReadyHandler will prevent additional messages
72 public void onNext(HelloRequest request) {
86 responseObserver.onNext(reply);
91 // cycling through the loop of onNext() -> request()...onNext() -> request()... until either the clien
    [all...]
  /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/routeguide/
RouteGuideServer.java 130 responseObserver.onNext(checkFeature(request));
155 responseObserver.onNext(feature);
178 public void onNext(Point point) {
199 responseObserver.onNext(RouteSummary.newBuilder().setPointCount(pointCount)
218 public void onNext(RouteNote note) {
223 responseObserver.onNext(prevNote);
  /external/grpc-grpc-java/alts/src/test/java/io/grpc/alts/internal/
AltsHandshakerStubTest.java 146 reader.onNext(HandshakerResp.newBuilder().build());
149 /** Mock writer onNext. Will respond based on the server status. */
151 public void onNext(final HandshakerReq req) {
155 reader.onNext(resp.setOutFrames(req.getNext().getInBytes()).build());
  /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/qps/
AsyncServer.java 215 responseObserver.onNext(Utils.makeResponse(request));
227 public void onNext(Messages.SimpleRequest value) {
232 responseObserver.onNext(Utils.makeResponse(value));
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/alts/src/main/java/io/grpc/alts/internal/
AltsHandshakerStub.java 62 writer.onNext(req);
85 public void onNext(HandshakerResp resp) {
  /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/header/
CustomHeaderServer.java 86 responseObserver.onNext(reply);
  /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/helloworld/
HelloWorldServer.java 81 responseObserver.onNext(reply);
  /external/grpc-grpc-java/benchmarks/src/jmh/java/io/grpc/benchmarks/netty/
AbstractBenchmark.java 399 public void onNext(ByteBuf value) {
441 public void onNext(ByteBuf value) {
448 requestObserverRef.get().onNext(request.slice());
468 requestObserver.onNext(request.slice());
469 requestObserver.onNext(request.slice());
495 public void onNext(ByteBuf value) {
525 requestObserver.onNext(request.slice());
  /external/grpc-grpc-java/benchmarks/src/test/java/io/grpc/benchmarks/driver/
LoadWorkerTest.java 187 clientObserver.onNext(MARK);
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/
ChannelzServiceTest.java 155 verify(observer).onNext(responseCaptor.capture());
166 verify(observer).onNext(response.capture());
187 verify(observer).onNext(response.capture());
210 verify(observer).onNext(responseCaptor.capture());
231 verify(observer).onNext(response.capture());
  /external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
GrpclbLoadBalancerTest.java 413 inOrder.verify(lbRequestObserver).onNext(
420 lbResponseObserver.onNext(buildInitialResponse(loadReportIntervalMillis));
432 lbResponseObserver.onNext(buildLbResponse(backends));
569 inOrder.verify(lbRequestObserver).onNext(
575 lbResponseObserver.onNext(buildInitialResponse(loadReportIntervalMillis));
591 lbResponseObserver.onNext(buildLbResponse(backends));
632 lbResponseObserver.onNext(buildInitialResponse(1983));
640 lbResponseObserver.onNext(buildInitialResponse(9097));
663 inOrder.verify(lbRequestObserver).onNext(
670 lbResponseObserver.onNext(buildInitialResponse(1983))
    [all...]
  /external/grpc-grpc-java/examples/example-kotlin/src/main/kotlin/io/grpc/examples/helloworld/
HelloWorldServer.kt 70 responseObserver.onNext(reply)

Completed in 517 milliseconds

1 2 3