| /external/grpc-grpc-java/examples/android/clientcache/app/src/test/java/io/grpc/clientcacheexample/ |
| D | SafeMethodCachingInterceptorTest.java | 27 import io.grpc.stub.ClientCalls;
135 ClientCalls.blockingUnaryCall( in safeCallsAreCached()
138 ClientCalls.blockingUnaryCall( in safeCallsAreCached()
147 ClientCalls.blockingUnaryCall( in safeCallsAreCachedWithCopiedMethodDescriptor()
150 ClientCalls.blockingUnaryCall( in safeCallsAreCachedWithCopiedMethodDescriptor()
162 ClientCalls.blockingUnaryCall( in requestWithNoCacheOptionSkipsCache()
165 ClientCalls.blockingUnaryCall( in requestWithNoCacheOptionSkipsCache()
171 ClientCalls.blockingUnaryCall( in requestWithNoCacheOptionSkipsCache()
181 ClientCalls.blockingUnaryCall( in requestWithOnlyIfCachedOption_unavailableIfNotInCache()
199 ClientCalls.blockingUnaryCall( in requestWithOnlyIfCachedOption_usesCache()
[all …]
|
| /external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/ |
| D | ClientCallsTest.java | 107 String actualResponse = ClientCalls.blockingUnaryCall(call, req); in unaryBlockingCallSuccess()
125 ClientCalls.blockingUnaryCall(call, req); in unaryBlockingCallFailed()
156 ListenableFuture<String> future = ClientCalls.futureUnaryCall(call, req); in unaryFutureCallSuccess()
176 ListenableFuture<String> future = ClientCalls.futureUnaryCall(call, req); in unaryFutureCallFailed()
209 ListenableFuture<String> future = ClientCalls.futureUnaryCall(call, req); in unaryFutureCallCancelled()
227 (CallStreamObserver<Integer>) ClientCalls.asyncClientStreamingCall(call, in cannotSetOnReadyAfterCallStarted()
259 ClientCalls.asyncBidiStreamingCall(call, new ClientResponseObserver<Integer, String>() { in disablingInboundAutoFlowControlSuppressesRequestsForMoreMessages()
322 ClientCalls.asyncBidiStreamingCall(call, responseObserver); in callStreamObserverPropagatesFlowControlRequestsToCall()
366 ClientCalls.asyncServerStreamingCall(call, 1, responseObserver); in canCaptureInboundFlowControlForServerStreamingObserver()
437 ClientCalls.asyncBidiStreamingCall(clientCall, responseObserver); in inprocessTransportInboundFlowControl()
[all …]
|
| /external/grpc-grpc-java/alts/src/generated/main/grpc/io/grpc/alts/internal/ |
| D | HandshakerServiceGrpc.java | 4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
5 import static io.grpc.stub.ClientCalls.asyncClientStreamingCall;
6 import static io.grpc.stub.ClientCalls.asyncServerStreamingCall;
7 import static io.grpc.stub.ClientCalls.asyncUnaryCall;
8 import static io.grpc.stub.ClientCalls.blockingServerStreamingCall;
9 import static io.grpc.stub.ClientCalls.blockingUnaryCall;
10 import static io.grpc.stub.ClientCalls.futureUnaryCall;
|
| /external/grpc-grpc-java/grpclb/src/generated/main/grpc/io/grpc/lb/v1/ |
| D | LoadBalancerGrpc.java | 4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
5 import static io.grpc.stub.ClientCalls.asyncClientStreamingCall;
6 import static io.grpc.stub.ClientCalls.asyncServerStreamingCall;
7 import static io.grpc.stub.ClientCalls.asyncUnaryCall;
8 import static io.grpc.stub.ClientCalls.blockingServerStreamingCall;
9 import static io.grpc.stub.ClientCalls.blockingUnaryCall;
10 import static io.grpc.stub.ClientCalls.futureUnaryCall;
|
| /external/grpc-grpc-java/services/src/generated/main/grpc/io/grpc/reflection/v1alpha/ |
| D | ServerReflectionGrpc.java | 4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
5 import static io.grpc.stub.ClientCalls.asyncClientStreamingCall;
6 import static io.grpc.stub.ClientCalls.asyncServerStreamingCall;
7 import static io.grpc.stub.ClientCalls.asyncUnaryCall;
8 import static io.grpc.stub.ClientCalls.blockingServerStreamingCall;
9 import static io.grpc.stub.ClientCalls.blockingUnaryCall;
10 import static io.grpc.stub.ClientCalls.futureUnaryCall;
|
| /external/grpc-grpc-java/interop-testing/src/generated/main/grpc/io/grpc/testing/integration/ |
| D | UnimplementedServiceGrpc.java | 4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
5 import static io.grpc.stub.ClientCalls.asyncClientStreamingCall;
6 import static io.grpc.stub.ClientCalls.asyncServerStreamingCall;
7 import static io.grpc.stub.ClientCalls.asyncUnaryCall;
8 import static io.grpc.stub.ClientCalls.blockingServerStreamingCall;
9 import static io.grpc.stub.ClientCalls.blockingUnaryCall;
10 import static io.grpc.stub.ClientCalls.futureUnaryCall;
|
| D | ReconnectServiceGrpc.java | 4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
5 import static io.grpc.stub.ClientCalls.asyncClientStreamingCall;
6 import static io.grpc.stub.ClientCalls.asyncServerStreamingCall;
7 import static io.grpc.stub.ClientCalls.asyncUnaryCall;
8 import static io.grpc.stub.ClientCalls.blockingServerStreamingCall;
9 import static io.grpc.stub.ClientCalls.blockingUnaryCall;
10 import static io.grpc.stub.ClientCalls.futureUnaryCall;
|
| D | MetricsServiceGrpc.java | 4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
5 import static io.grpc.stub.ClientCalls.asyncClientStreamingCall;
6 import static io.grpc.stub.ClientCalls.asyncServerStreamingCall;
7 import static io.grpc.stub.ClientCalls.asyncUnaryCall;
8 import static io.grpc.stub.ClientCalls.blockingServerStreamingCall;
9 import static io.grpc.stub.ClientCalls.blockingUnaryCall;
10 import static io.grpc.stub.ClientCalls.futureUnaryCall;
|
| D | TestServiceGrpc.java | 4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
5 import static io.grpc.stub.ClientCalls.asyncClientStreamingCall;
6 import static io.grpc.stub.ClientCalls.asyncServerStreamingCall;
7 import static io.grpc.stub.ClientCalls.asyncUnaryCall;
8 import static io.grpc.stub.ClientCalls.blockingServerStreamingCall;
9 import static io.grpc.stub.ClientCalls.blockingUnaryCall;
10 import static io.grpc.stub.ClientCalls.futureUnaryCall;
|
| /external/grpc-grpc-java/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/ |
| D | ReportQpsScenarioServiceGrpc.java | 4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
5 import static io.grpc.stub.ClientCalls.asyncClientStreamingCall;
6 import static io.grpc.stub.ClientCalls.asyncServerStreamingCall;
7 import static io.grpc.stub.ClientCalls.asyncUnaryCall;
8 import static io.grpc.stub.ClientCalls.blockingServerStreamingCall;
9 import static io.grpc.stub.ClientCalls.blockingUnaryCall;
10 import static io.grpc.stub.ClientCalls.futureUnaryCall;
|
| D | WorkerServiceGrpc.java | 4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
5 import static io.grpc.stub.ClientCalls.asyncClientStreamingCall;
6 import static io.grpc.stub.ClientCalls.asyncServerStreamingCall;
7 import static io.grpc.stub.ClientCalls.asyncUnaryCall;
8 import static io.grpc.stub.ClientCalls.blockingServerStreamingCall;
9 import static io.grpc.stub.ClientCalls.blockingUnaryCall;
10 import static io.grpc.stub.ClientCalls.futureUnaryCall;
|
| D | BenchmarkServiceGrpc.java | 4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
5 import static io.grpc.stub.ClientCalls.asyncClientStreamingCall;
6 import static io.grpc.stub.ClientCalls.asyncServerStreamingCall;
7 import static io.grpc.stub.ClientCalls.asyncUnaryCall;
8 import static io.grpc.stub.ClientCalls.blockingServerStreamingCall;
9 import static io.grpc.stub.ClientCalls.blockingUnaryCall;
10 import static io.grpc.stub.ClientCalls.futureUnaryCall;
|
| /external/grpc-grpc-java/services/src/generated/test/grpc/io/grpc/reflection/testing/ |
| D | AnotherDynamicServiceGrpc.java | 4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
5 import static io.grpc.stub.ClientCalls.asyncClientStreamingCall;
6 import static io.grpc.stub.ClientCalls.asyncServerStreamingCall;
7 import static io.grpc.stub.ClientCalls.asyncUnaryCall;
8 import static io.grpc.stub.ClientCalls.blockingServerStreamingCall;
9 import static io.grpc.stub.ClientCalls.blockingUnaryCall;
10 import static io.grpc.stub.ClientCalls.futureUnaryCall;
|
| D | ReflectableServiceGrpc.java | 4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
5 import static io.grpc.stub.ClientCalls.asyncClientStreamingCall;
6 import static io.grpc.stub.ClientCalls.asyncServerStreamingCall;
7 import static io.grpc.stub.ClientCalls.asyncUnaryCall;
8 import static io.grpc.stub.ClientCalls.blockingServerStreamingCall;
9 import static io.grpc.stub.ClientCalls.blockingUnaryCall;
10 import static io.grpc.stub.ClientCalls.futureUnaryCall;
|
| D | DynamicServiceGrpc.java | 4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
5 import static io.grpc.stub.ClientCalls.asyncClientStreamingCall;
6 import static io.grpc.stub.ClientCalls.asyncServerStreamingCall;
7 import static io.grpc.stub.ClientCalls.asyncUnaryCall;
8 import static io.grpc.stub.ClientCalls.blockingServerStreamingCall;
9 import static io.grpc.stub.ClientCalls.blockingUnaryCall;
10 import static io.grpc.stub.ClientCalls.futureUnaryCall;
|
| /external/grpc-grpc-java/services/src/generated/main/grpc/io/grpc/health/v1/ |
| D | HealthGrpc.java | 4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
5 import static io.grpc.stub.ClientCalls.asyncClientStreamingCall;
6 import static io.grpc.stub.ClientCalls.asyncServerStreamingCall;
7 import static io.grpc.stub.ClientCalls.asyncUnaryCall;
8 import static io.grpc.stub.ClientCalls.blockingServerStreamingCall;
9 import static io.grpc.stub.ClientCalls.blockingUnaryCall;
10 import static io.grpc.stub.ClientCalls.futureUnaryCall;
|
| /external/grpc-grpc-java/benchmarks/src/jmh/java/io/grpc/benchmarks/netty/ |
| D | SingleThreadBlockingQpsBenchmark.java | 20 import io.grpc.stub.ClientCalls;
69 return ClientCalls.blockingUnaryCall( in blockingUnary()
|
| D | AbstractBenchmark.java | 35 import io.grpc.stub.ClientCalls;
412 ClientCalls.asyncUnaryCall( in startUnaryCalls()
437 StreamObserver<ByteBuf> requestObserver = ClientCalls.asyncBidiStreamingCall( in startStreamingCalls()
491 StreamObserver<ByteBuf> requestObserver = ClientCalls.asyncBidiStreamingCall( in startFlowControlledStreamingCalls()
|
| /external/grpc-grpc-java/compiler/src/testLite/golden/ |
| D | TestDeprecatedService.java.txt | 4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
5 import static io.grpc.stub.ClientCalls.asyncClientStreamingCall;
6 import static io.grpc.stub.ClientCalls.asyncServerStreamingCall;
7 import static io.grpc.stub.ClientCalls.asyncUnaryCall;
8 import static io.grpc.stub.ClientCalls.blockingServerStreamingCall;
9 import static io.grpc.stub.ClientCalls.blockingUnaryCall;
10 import static io.grpc.stub.ClientCalls.futureUnaryCall;
|
| /external/grpc-grpc-java/compiler/src/testNano/golden/ |
| D | TestDeprecatedService.java.txt | 4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
5 import static io.grpc.stub.ClientCalls.asyncClientStreamingCall;
6 import static io.grpc.stub.ClientCalls.asyncServerStreamingCall;
7 import static io.grpc.stub.ClientCalls.asyncUnaryCall;
8 import static io.grpc.stub.ClientCalls.blockingServerStreamingCall;
9 import static io.grpc.stub.ClientCalls.blockingUnaryCall;
10 import static io.grpc.stub.ClientCalls.futureUnaryCall;
|
| /external/flatbuffers/tests/MyGame/Example/ |
| D | MonsterStorageGrpc.java | 11 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
12 import static io.grpc.stub.ClientCalls.asyncClientStreamingCall;
13 import static io.grpc.stub.ClientCalls.asyncServerStreamingCall;
14 import static io.grpc.stub.ClientCalls.asyncUnaryCall;
15 import static io.grpc.stub.ClientCalls.blockingServerStreamingCall;
16 import static io.grpc.stub.ClientCalls.blockingUnaryCall;
17 import static io.grpc.stub.ClientCalls.futureUnaryCall;
|
| /external/grpc-grpc-java/compiler/src/test/golden/ |
| D | TestDeprecatedService.java.txt | 4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
5 import static io.grpc.stub.ClientCalls.asyncClientStreamingCall;
6 import static io.grpc.stub.ClientCalls.asyncServerStreamingCall;
7 import static io.grpc.stub.ClientCalls.asyncUnaryCall;
8 import static io.grpc.stub.ClientCalls.blockingServerStreamingCall;
9 import static io.grpc.stub.ClientCalls.blockingUnaryCall;
10 import static io.grpc.stub.ClientCalls.futureUnaryCall;
|
| /external/grpc-grpc-java/testing-proto/src/generated/main/grpc/io/grpc/testing/protobuf/ |
| D | SimpleServiceGrpc.java | 4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
5 import static io.grpc.stub.ClientCalls.asyncClientStreamingCall;
6 import static io.grpc.stub.ClientCalls.asyncServerStreamingCall;
7 import static io.grpc.stub.ClientCalls.asyncUnaryCall;
8 import static io.grpc.stub.ClientCalls.blockingServerStreamingCall;
9 import static io.grpc.stub.ClientCalls.blockingUnaryCall;
10 import static io.grpc.stub.ClientCalls.futureUnaryCall;
|
| /external/grpc-grpc-java/services/src/generated/main/grpc/io/grpc/channelz/v1/ |
| D | ChannelzGrpc.java | 4 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
5 import static io.grpc.stub.ClientCalls.asyncClientStreamingCall;
6 import static io.grpc.stub.ClientCalls.asyncServerStreamingCall;
7 import static io.grpc.stub.ClientCalls.asyncUnaryCall;
8 import static io.grpc.stub.ClientCalls.blockingServerStreamingCall;
9 import static io.grpc.stub.ClientCalls.blockingUnaryCall;
10 import static io.grpc.stub.ClientCalls.futureUnaryCall;
|
| /external/grpc-grpc-java/examples/android/clientcache/app/src/main/java/io/grpc/clientcacheexample/ |
| D | ClientCacheExampleActivity.java | 42 import io.grpc.stub.ClientCalls;
133 ClientCalls.blockingUnaryCall( in doInBackground()
|