/external/grpc-grpc-java/core/src/main/java/io/grpc/ |
ClientInterceptor.java | 50 <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(
|
ServerInterceptor.java | 50 <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall(
|
ClientInterceptors.java | 37 * given channel. The first interceptor will have its {@link ClientInterceptor#interceptCall} 50 * given channel. The first interceptor will have its {@link ClientInterceptor#interceptCall} 66 * given channel. The last interceptor will have its {@link ClientInterceptor#interceptCall} 79 * given channel. The last interceptor will have its {@link ClientInterceptor#interceptCall} 104 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( 109 interceptor.interceptCall(wrappedMethod, callOptions, next); 156 return interceptor.interceptCall(method, callOptions, channel);
|
Contexts.java | 44 public static <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall(
|
/external/grpc-grpc-java/core/src/test/java/io/grpc/ |
ClientInterceptorsTest.java | 102 verify(interceptor).interceptCall(same(method), same(callOptions), Mockito.<Channel>any()); 108 .interceptCall(same(method), same(callOptions), Mockito.<Channel>any()); 116 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( 150 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( 160 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( 192 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( 202 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( 223 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( 232 verify(interceptor).interceptCall( 242 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( [all...] |
ServerInterceptorsTest.java | 129 verify(interceptor).interceptCall(same(call), same(headers), anyCallHandler()); 136 .interceptCall(same(call), same(headers), anyCallHandler()); 168 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall( 199 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall( 209 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall( 241 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall( 251 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall( 279 public <R1, R2> ServerCall.Listener<R1> interceptCall( 338 public <ReqT, RespT> Listener<ReqT> interceptCall(ServerCall<ReqT, RespT> call, 367 public <ReqT, RespT> Listener<ReqT> interceptCall(ServerCall<ReqT, RespT> call [all...] |
ContextsTest.java | 19 import static io.grpc.Contexts.interceptCall; 86 ServerCall.Listener<Object> wrapped = interceptCall(uniqueContext, call, headers, 112 interceptCall(uniqueContext, call, headers, new ServerCallHandler<Object, Object>() { 149 ServerCall.Listener<Object> wrapped = interceptCall(uniqueContext, call, headers,
|
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
ServiceConfigInterceptorTest.java | 98 interceptor.interceptCall(methodDescriptor, CallOptions.DEFAULT.withoutWaitForReady(), channel); 106 interceptor.interceptCall(methodDescriptor, CallOptions.DEFAULT.withoutWaitForReady(), channel); 124 interceptor.interceptCall(methodDescriptor, CallOptions.DEFAULT, channel); 138 interceptor.interceptCall( 153 interceptor.interceptCall( 168 interceptor.interceptCall(methodDescriptor, CallOptions.DEFAULT, channel); 182 interceptor.interceptCall( 197 interceptor.interceptCall( 212 interceptor.interceptCall(methodDescriptor, CallOptions.DEFAULT.withWaitForReady(), channel); 231 interceptor.interceptCall(methodDescriptor, CallOptions.DEFAULT, channel) [all...] |
HedgingPolicyTest.java | 144 serviceConfigInterceptor.interceptCall(method, CallOptions.DEFAULT, channel);
|
/external/grpc-grpc-java/examples/src/test/java/io/grpc/examples/header/ |
HeaderClientInterceptorTest.java | 69 public <ReqT, RespT> Listener<ReqT> interceptCall( 97 verify(mockServerInterceptor).interceptCall(
|
HeaderServerInterceptorTest.java | 95 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(
|
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/header/ |
HeaderClientInterceptor.java | 42 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(MethodDescriptor<ReqT, RespT> method,
|
HeaderServerInterceptor.java | 40 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall(
|
/external/grpc-grpc-java/auth/src/test/java/io/grpc/auth/ |
ClientAuthInterceptorTest.java | 116 interceptor.interceptCall(descriptor, CallOptions.DEFAULT, channel); 134 interceptor.interceptCall(descriptor, CallOptions.DEFAULT, channel); 157 interceptor.interceptCall(descriptor, CallOptions.DEFAULT, channel); 172 interceptedCall = interceptor.interceptCall(descriptor, CallOptions.DEFAULT, channel); 178 interceptedCall = interceptor.interceptCall(descriptor, CallOptions.DEFAULT, channel);
|
/external/grpc-grpc-java/services/src/main/java/io/grpc/services/ |
BinaryLogProvider.java | 145 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( 159 .interceptCall(method, callOptions, next);
|
/external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/ |
MetadataUtils.java | 72 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( 136 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(
|
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/ |
TransportCompressionTest.java | 94 public <ReqT, RespT> Listener<ReqT> interceptCall(ServerCall<ReqT, RespT> call, 135 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(
|
CompressionTest.java | 261 public <ReqT, RespT> io.grpc.ServerCall.Listener<ReqT> interceptCall( 276 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(
|
/external/grpc-grpc-java/auth/src/main/java/io/grpc/auth/ |
ClientAuthInterceptor.java | 61 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(
|
/external/grpc-grpc-java/testing/src/main/java/io/grpc/testing/ |
TestUtils.java | 56 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall(
|
/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
TestServiceImpl.java | 511 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall( 539 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall( 566 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall(
|
/external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/ |
AltsChannelBuilder.java | 234 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(
|
AltsServerBuilder.java | 225 public <ReqT, RespT> Listener<ReqT> interceptCall(
|
GoogleDefaultChannelBuilder.java | 187 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(
|
/external/grpc-grpc-java/android-interop-testing/app/src/main/java/io/grpc/android/integrationtest/ |
TesterActivity.java | 155 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(
|