Home
last modified time | relevance | path

Searched refs:interceptCall (Results 1 – 25 of 43) sorted by relevance

12

/external/grpc-grpc-java/core/src/test/java/io/grpc/
DClientInterceptorsTest.java102 verify(interceptor).interceptCall(same(method), same(callOptions), Mockito.<Channel>any()); in channelAndInterceptorCalled()
108 .interceptCall(same(method), same(callOptions), Mockito.<Channel>any()); in channelAndInterceptorCalled()
116 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in callNextTwice()
150 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in ordered()
160 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in ordered()
192 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in orderedForward()
202 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in orderedForward()
223 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in callOptions()
232 verify(interceptor).interceptCall( in callOptions()
242 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in addOutboundHeaders()
[all …]
DServerInterceptorsTest.java129 verify(interceptor).interceptCall(same(call), same(headers), anyCallHandler()); in multipleInvocationsOfHandler()
136 .interceptCall(same(call), same(headers), anyCallHandler()); in multipleInvocationsOfHandler()
168 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall( in callNextTwice()
199 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall( in ordered()
209 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall( in ordered()
241 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall( in orderedForward()
251 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall( in orderedForward()
279 public <R1, R2> ServerCall.Listener<R1> interceptCall( in argumentsPassed()
338 public <ReqT, RespT> Listener<ReqT> interceptCall(ServerCall<ReqT, RespT> call, in typedMarshalledMessages()
367 public <ReqT, RespT> Listener<ReqT> interceptCall(ServerCall<ReqT, RespT> call, in typedMarshalledMessages()
[all …]
DContextsTest.java19 import static io.grpc.Contexts.interceptCall;
86 ServerCall.Listener<Object> wrapped = interceptCall(uniqueContext, call, headers, in interceptCall_basic()
112 interceptCall(uniqueContext, call, headers, new ServerCallHandler<Object, Object>() { in interceptCall_restoresIfNextThrows()
149 ServerCall.Listener<Object> wrapped = interceptCall(uniqueContext, call, headers, in interceptCall_restoresIfListenerThrows()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DServiceConfigInterceptorTest.java98 interceptor.interceptCall(methodDescriptor, CallOptions.DEFAULT.withoutWaitForReady(), channel); in withWaitForReady()
106 interceptor.interceptCall(methodDescriptor, CallOptions.DEFAULT.withoutWaitForReady(), channel); in handleUpdateNotCalledBeforeInterceptCall()
124 interceptor.interceptCall(methodDescriptor, CallOptions.DEFAULT, channel); in withMaxRequestSize()
138 interceptor.interceptCall( in withMaxRequestSize_pickSmallerExisting()
153 interceptor.interceptCall( in withMaxRequestSize_pickSmallerNew()
168 interceptor.interceptCall(methodDescriptor, CallOptions.DEFAULT, channel); in withMaxResponseSize()
182 interceptor.interceptCall( in withMaxResponseSize_pickSmallerExisting()
197 interceptor.interceptCall( in withMaxResponseSize_pickSmallerNew()
212 interceptor.interceptCall(methodDescriptor, CallOptions.DEFAULT.withWaitForReady(), channel); in withoutWaitForReady()
231 interceptor.interceptCall(methodDescriptor, CallOptions.DEFAULT, channel); in fullMethodMatched()
[all …]
DHedgingPolicyTest.java144 serviceConfigInterceptor.interceptCall(method, CallOptions.DEFAULT, channel); in getRetryPolicies_hedgingDisabled()
/external/grpc-grpc-java/auth/src/test/java/io/grpc/auth/
DClientAuthInterceptorTest.java116 interceptor.interceptCall(descriptor, CallOptions.DEFAULT, channel); in testCopyCredentialToHeaders()
134 interceptor.interceptCall(descriptor, CallOptions.DEFAULT, channel); in testCredentialsThrows()
157 interceptor.interceptCall(descriptor, CallOptions.DEFAULT, channel); in testWithOAuth2Credential()
172 interceptedCall = interceptor.interceptCall(descriptor, CallOptions.DEFAULT, channel); in verifyServiceUri()
178 interceptedCall = interceptor.interceptCall(descriptor, CallOptions.DEFAULT, channel); in verifyServiceUri()
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DClientInterceptors.java104 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in wrapClientInterceptor()
109 interceptor.interceptCall(wrappedMethod, callOptions, next); in wrapClientInterceptor()
156 return interceptor.interceptCall(method, callOptions, channel);
DClientInterceptor.java50 <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in interceptCall() method
DServerInterceptor.java50 <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall( in interceptCall() method
DContexts.java44 public static <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall( in interceptCall() method in Contexts
/external/grpc-grpc-java/examples/src/test/java/io/grpc/examples/header/
DHeaderClientInterceptorTest.java69 public <ReqT, RespT> Listener<ReqT> interceptCall(
97 verify(mockServerInterceptor).interceptCall( in clientHeaderDeliveredToServer()
DHeaderServerInterceptorTest.java95 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in serverHeaderDeliveredToClient() method in HeaderServerInterceptorTest.SpyingClientInterceptor
/external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/
DMetadataUtils.java72 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in interceptCall() method in MetadataUtils.HeaderAttachingClientInterceptor
136 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in interceptCall() method in MetadataUtils.MetadataCapturingClientInterceptor
/external/grpc-grpc-java/services/src/main/java/io/grpc/services/
DBinaryLogProvider.java145 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in interceptCall() method in BinaryLogProvider.BinaryLogShim
159 .interceptCall(method, callOptions, next); in interceptCall()
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DTransportCompressionTest.java94 public <ReqT, RespT> Listener<ReqT> interceptCall(ServerCall<ReqT, RespT> call, in getServerBuilder()
135 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(
DCompressionTest.java261 public <ReqT, RespT> io.grpc.ServerCall.Listener<ReqT> interceptCall( in interceptCall() method in CompressionTest.ServerCompressorInterceptor
276 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in interceptCall() method in CompressionTest.ClientCompressorInterceptor
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/header/
DHeaderServerInterceptor.java40 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall( in interceptCall() method in HeaderServerInterceptor
DHeaderClientInterceptor.java42 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(MethodDescriptor<ReqT, RespT> method, in interceptCall() method in HeaderClientInterceptor
/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
DTestServiceImpl.java511 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/testing/src/main/java/io/grpc/testing/
DTestUtils.java56 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall( in recordRequestHeadersInterceptor()
/external/grpc-grpc-java/auth/src/main/java/io/grpc/auth/
DClientAuthInterceptor.java61 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in interceptCall() method in ClientAuthInterceptor
/external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/
DGoogleDefaultChannelBuilder.java187 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(
/external/grpc-grpc-java/android-interop-testing/app/src/main/java/io/grpc/android/integrationtest/
DTesterActivity.java155 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in interceptCall() method in TesterActivity.SafeMethodChannelInterceptor
/external/grpc-grpc-java/services/src/test/java/io/grpc/services/
DBinaryLogProviderTest.java306 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in interceptCall() method in BinaryLogProviderTest.TestBinaryLogClientInterceptor
348 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall(
/external/grpc-grpc-java/core/src/main/java/io/grpc/util/
DTransmitStatusRuntimeExceptionInterceptor.java57 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall( in interceptCall() method in TransmitStatusRuntimeExceptionInterceptor

12