OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
refs:onCompleted
(Results
1 - 25
of
62
) sorted by null
1
2
3
/external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/
StreamObserver.java
40
* #
onCompleted
()} are called.
75
* exception is thrown by an implementation of {@code
onCompleted
} no further calls to any method
78
void
onCompleted
();
StreamObservers.java
53
target.
onCompleted
();
/external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/
LoadWorker.java
158
onCompleted
();
168
onCompleted
();
172
public void
onCompleted
() {
179
responseObserver.
onCompleted
();
210
onCompleted
();
220
onCompleted
();
224
public void
onCompleted
() {
231
responseObserver.
onCompleted
();
244
responseObserver.
onCompleted
();
253
responseObserver.
onCompleted
();
[
all
...]
/external/grpc-grpc-java/services/src/main/java/io/grpc/services/
ChannelzService.java
72
responseObserver.
onCompleted
();
90
responseObserver.
onCompleted
();
100
responseObserver.
onCompleted
();
118
responseObserver.
onCompleted
();
136
responseObserver.
onCompleted
();
150
responseObserver.
onCompleted
();
HealthServiceImpl.java
49
responseObserver.
onCompleted
();
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/manualflowcontrol/
ManualFlowControlServer.java
113
responseObserver.
onCompleted
();
117
public void
onCompleted
() {
120
responseObserver.
onCompleted
();
ManualFlowControlClient.java
86
requestStream.
onCompleted
();
107
public void
onCompleted
() {
/external/grpc-grpc-java/services/src/test/java/io/grpc/protobuf/services/
ProtoReflectionServiceTest.java
186
requestObserver.
onCompleted
();
214
requestObserver.
onCompleted
();
220
requestObserver2.
onCompleted
();
225
requestObserver3.
onCompleted
();
255
requestObserver.
onCompleted
();
290
requestObserver.
onCompleted
();
317
requestObserver.
onCompleted
();
323
requestObserver2.
onCompleted
();
328
requestObserver3.
onCompleted
();
362
requestObserver.
onCompleted
();
[
all
...]
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
MoreInProcessTest.java
86
responseObserver.
onCompleted
();
97
public void
onCompleted
() {
122
public void
onCompleted
() {
145
responseObserver.
onCompleted
();
156
public void
onCompleted
() {
181
public void
onCompleted
() {
214
public void
onCompleted
() {
240
public void
onCompleted
() {
/external/flatbuffers/grpc/tests/
JavaGrpcTest.java
62
responseObserver.
onCompleted
();
72
responseObserver.
onCompleted
();
118
public void
onCompleted
() {
127
responseObserver.
onCompleted
();
180
public void
onCompleted
() {
194
monsterStream.
onCompleted
();
209
public void
onCompleted
() {
229
monsterStream.
onCompleted
();
/external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/qps/
AsyncServer.java
216
responseObserver.
onCompleted
();
229
responseObserver.
onCompleted
();
242
public void
onCompleted
() {
244
responseObserver.
onCompleted
();
258
responseObserver.
onCompleted
();
271
public void
onCompleted
() {
274
responseObserver.
onCompleted
();
293
// responseObserver.
onCompleted
() for us
321
// responseObserver.
onCompleted
() for us
354
public void
onCompleted
() {
[
all
...]
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/routeguide/
RouteGuideServer.java
131
responseObserver.
onCompleted
();
158
responseObserver.
onCompleted
();
197
public void
onCompleted
() {
202
responseObserver.
onCompleted
();
236
public void
onCompleted
() {
237
responseObserver.
onCompleted
();
/external/grpc-grpc-java/alts/src/test/java/io/grpc/alts/internal/
AltsHandshakerStubTest.java
161
reader.
onCompleted
();
173
public void
onCompleted
() {
174
reader.
onCompleted
();
/external/grpc-grpc-java/services/src/test/java/io/grpc/services/
HealthStatusManagerTest.java
70
inOrder.verify(observer, times(1)).
onCompleted
();
91
verify(observer, never()).
onCompleted
();
112
verify(observer, never()).
onCompleted
();
ChannelzServiceTest.java
156
verify(observer).
onCompleted
();
167
verify(observer).
onCompleted
();
188
verify(observer).
onCompleted
();
211
verify(observer).
onCompleted
();
232
verify(observer).
onCompleted
();
/external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/internal/
AltsHandshakerStub.java
79
writer.
onCompleted
();
107
public void
onCompleted
() {
/external/opencensus-java/exporters/trace/ocagent/src/test/java/io/opencensus/exporter/trace/ocagent/
FakeOcAgentTraceServiceGrpcImplTest.java
52
public void
onCompleted
() {}
64
public void
onCompleted
() {}
FakeOcAgentTraceServiceGrpcImpl.java
81
public void
onCompleted
() {}
97
public void
onCompleted
() {}
/external/grpc-grpc-java/examples/src/test/java/io/grpc/examples/routeguide/
RouteGuideClientTest.java
123
responseObserver.
onCompleted
();
184
responseObserver.
onCompleted
();
283
public void
onCompleted
() {
285
responseObserver.
onCompleted
();
338
public void
onCompleted
() {
384
public void
onCompleted
() {
420
responseObserverRef.get().
onCompleted
();
452
public void
onCompleted
() {
453
responseObserver.
onCompleted
();
500
public void
onCompleted
() {
[
all
...]
/external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/
ClientCallsTest.java
276
public void
onCompleted
() {
303
public void
onCompleted
() {
349
public void
onCompleted
() {
396
public void
onCompleted
() {
397
serverCallObserver.
onCompleted
();
431
public void
onCompleted
() {
442
integerStreamObserver.
onCompleted
();
477
public void
onCompleted
() {
478
serverCallObserver.
onCompleted
();
506
requestStream.
onCompleted
();
[
all
...]
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/header/
CustomHeaderServer.java
87
responseObserver.
onCompleted
();
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/helloworld/
HelloWorldServer.java
82
responseObserver.
onCompleted
();
/external/grpc-grpc-java/benchmarks/src/jmh/java/io/grpc/benchmarks/netty/
AbstractBenchmark.java
409
public void
onCompleted
() {
417
observer.
onCompleted
();
444
requestObserverRef.get().
onCompleted
();
463
public void
onCompleted
() {
499
obs.
onCompleted
();
517
public void
onCompleted
() {
/external/grpc-grpc-java/examples/example-kotlin/src/main/kotlin/io/grpc/examples/helloworld/
HelloWorldServer.kt
71
responseObserver.
onCompleted
()
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/advanced/
HelloJsonServer.java
98
responseObserver.
onCompleted
();
Completed in 328 milliseconds
1
2
3