OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
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