Home
last modified time | relevance | path

Searched refs:ClientCall (Results 1 – 25 of 52) sorted by relevance

123

/external/grpc-grpc-java/core/src/test/java/io/grpc/
DClientInterceptorsTest.java116 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in callNextTwice()
137 public <ReqT, RespT> ClientCall<ReqT, RespT> newCall( in ordered()
140 return (ClientCall<ReqT, RespT>) call; in ordered()
150 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in ordered()
160 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in ordered()
179 public <ReqT, RespT> ClientCall<ReqT, RespT> newCall( in orderedForward()
182 return (ClientCall<ReqT, RespT>) call; in orderedForward()
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()
[all …]
/external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/
DClientCalls.java27 import io.grpc.ClientCall;
62 ClientCall<ReqT, RespT> call, ReqT req, StreamObserver<RespT> responseObserver) { in asyncUnaryCall()
72 ClientCall<ReqT, RespT> call, ReqT req, StreamObserver<RespT> responseObserver) { in asyncServerStreamingCall()
84 ClientCall<ReqT, RespT> call, in asyncClientStreamingCall()
96 ClientCall<ReqT, RespT> call, StreamObserver<RespT> responseObserver) { in asyncBidiStreamingCall()
106 public static <ReqT, RespT> RespT blockingUnaryCall(ClientCall<ReqT, RespT> call, ReqT req) { in blockingUnaryCall()
125 ClientCall<ReqT, RespT> call = channel.newCall(method, callOptions.withExecutor(executor)); in blockingUnaryCall()
156 ClientCall<ReqT, RespT> call, ReqT req) { in blockingServerStreamingCall()
173 ClientCall<ReqT, RespT> call = channel.newCall(method, callOptions.withExecutor(executor)); in blockingServerStreamingCall()
187 ClientCall<ReqT, RespT> call, ReqT req) { in futureUnaryCall()
[all …]
DMetadataUtils.java23 import io.grpc.ClientCall;
72 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in interceptCall()
81 HeaderAttachingClientCall(ClientCall<ReqT, RespT> call) { in HeaderAttachingClientCall()
136 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in interceptCall()
145 MetadataCapturingClientCall(ClientCall<ReqT, RespT> call) { in MetadataCapturingClientCall()
150 public void start(ClientCall.Listener<RespT> responseListener, Metadata headers) { in start()
159 MetadataCapturingClientCallListener(ClientCall.Listener<RespT> responseListener) { in MetadataCapturingClientCallListener()
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DClientInterceptors.java104 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in wrapClientInterceptor()
108 final ClientCall<WReqT, WRespT> wrappedCall = in wrapClientInterceptor()
136 protected ClientCall<?, ?> delegate() { in wrapClientInterceptor()
154 public <ReqT, RespT> ClientCall<ReqT, RespT> newCall(
165 private static final ClientCall<Object, Object> NOOP_CALL = new ClientCall<Object, Object>() {
203 private ClientCall<ReqT, RespT> delegate;
218 protected CheckedForwardingClientCall(ClientCall<ReqT, RespT> delegate) {
223 protected final ClientCall<ReqT, RespT> delegate() {
238 delegate = (ClientCall<ReqT, RespT>) NOOP_CALL;
DForwardingClientCallListener.java29 protected abstract ClientCall.Listener<RespT> delegate(); in delegate()
43 private final ClientCall.Listener<RespT> delegate;
45 protected SimpleForwardingClientCallListener(ClientCall.Listener<RespT> delegate) { in SimpleForwardingClientCallListener()
50 protected ClientCall.Listener<RespT> delegate() { in delegate()
DForwardingClientCall.java28 protected abstract ClientCall<ReqT, RespT> delegate(); in delegate()
46 private final ClientCall<ReqT, RespT> delegate;
48 protected SimpleForwardingClientCall(ClientCall<ReqT, RespT> delegate) { in SimpleForwardingClientCall()
53 protected ClientCall<ReqT, RespT> delegate() { in delegate()
DPartialForwardingClientCallListener.java26 abstract class PartialForwardingClientCallListener<RespT> extends ClientCall.Listener<RespT> {
30 protected abstract ClientCall.Listener<?> delegate(); in delegate()
DPartialForwardingClientCall.java26 abstract class PartialForwardingClientCall<ReqT, RespT> extends ClientCall<ReqT, RespT> {
30 protected abstract ClientCall<?, ?> delegate(); in delegate()
/external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/
DClientCallsTest.java29 import io.grpc.ClientCall;
101 public void start(ClientCall.Listener<String> listener, Metadata headers) { in unaryBlockingCallSuccess()
119 public void start(io.grpc.ClientCall.Listener<String> listener, Metadata headers) { in unaryBlockingCallFailed()
135 final AtomicReference<ClientCall.Listener<String>> listener = in unaryFutureCallSuccess()
136 new AtomicReference<ClientCall.Listener<String>>(); in unaryFutureCallSuccess()
141 public void start(io.grpc.ClientCall.Listener<String> responseListener, Metadata headers) { in unaryFutureCallSuccess()
167 final AtomicReference<ClientCall.Listener<String>> listener = in unaryFutureCallFailed()
168 new AtomicReference<ClientCall.Listener<String>>(); in unaryFutureCallFailed()
171 public void start(io.grpc.ClientCall.Listener<String> responseListener, Metadata headers) { in unaryFutureCallFailed()
192 final AtomicReference<ClientCall.Listener<String>> listener = in unaryFutureCallCancelled()
[all …]
/external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/
DNoopClientCall.java19 import io.grpc.ClientCall;
27 public class NoopClientCall<ReqT, RespT> extends ClientCall<ReqT, RespT> {
34 public static class NoopClientCallListener<T> extends ClientCall.Listener<T> {
38 public void start(ClientCall.Listener<RespT> listener, Metadata headers) {} in start()
/external/grpc-grpc-java/auth/src/test/java/io/grpc/auth/
DClientAuthInterceptorTest.java38 import io.grpc.ClientCall;
83 ClientCall.Listener<Integer> listener;
115 ClientCall<String, Integer> interceptedCall = in testCopyCredentialToHeaders()
133 ClientCall<String, Integer> interceptedCall = in testCredentialsThrows()
156 ClientCall<String, Integer> interceptedCall = in testWithOAuth2Credential()
169 ClientCall<String, Integer> interceptedCall; in verifyServiceUri()
184 private static final class ClientCallRecorder extends ClientCall<String, Integer> {
185 private ClientCall.Listener<Integer> responseListener;
194 public void start(ClientCall.Listener<Integer> responseListener, Metadata headers) { in start()
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DTransportCompressionTest.java26 import io.grpc.ClientCall;
135 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(
137 final ClientCall<ReqT, RespT> call = next.newCall(method, callOptions);
141 protected ClientCall<ReqT, RespT> delegate() {
147 final ClientCall.Listener<RespT> responseListener, Metadata headers) {
148 ClientCall.Listener<RespT> listener = new ForwardingClientCallListener<RespT>() {
151 protected io.grpc.ClientCall.Listener<RespT> delegate() {
DCompressionTest.java30 import io.grpc.ClientCall;
31 import io.grpc.ClientCall.Listener;
276 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in interceptCall()
281 ClientCall<ReqT, RespT> call = next.newCall(method, callOptions); in interceptCall()
288 protected ClientCompressor(ClientCall<ReqT, RespT> delegate) { in ClientCompressor()
293 public void start(io.grpc.ClientCall.Listener<RespT> responseListener, Metadata headers) { in start()
/external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/
DFailingClientCall.java19 import io.grpc.ClientCall;
24 final class FailingClientCall<ReqT, RespT> extends ClientCall<ReqT, RespT> {
33 public void start(ClientCall.Listener<RespT> listener, Metadata headers) { in start()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DManagedChannelImplIdlenessTest.java37 import io.grpc.ClientCall;
108 @Mock private ClientCall.Listener<Integer> mockCallListener;
109 @Mock private ClientCall.Listener<Integer> mockCallListener2;
178 ClientCall<String, Integer> call = channel.newCall(method, CallOptions.DEFAULT); in newCallExitsIdleness()
193 ClientCall<String, Integer> call = channel.newCall(method, CallOptions.DEFAULT); in newCallRefreshesIdlenessTimer()
230 ClientCall<String, Integer> call = channel.newCall(method, CallOptions.DEFAULT); in delayedTransportHoldsOffIdleness()
255 ClientCall<String, Integer> call = channel.newCall(method, CallOptions.DEFAULT); in realTransportsHoldsOffIdleness()
299 ClientCall<String, Integer> call = channel.newCall(method, CallOptions.DEFAULT); in updateSubchannelAddresses_newAddressConnects()
319 ClientCall<String, Integer> call = channel.newCall(method, CallOptions.DEFAULT); in updateSubchannelAddresses_existingAddressDoesNotConnect()
341 ClientCall<String, Integer> call = channel.newCall(method, CallOptions.DEFAULT); in oobTransportDoesNotAffectIdleness()
[all …]
DManagedChannelImplTest.java62 import io.grpc.ClientCall;
191 private ClientCall.Listener<Integer> mockCallListener;
193 private ClientCall.Listener<Integer> mockCallListener2;
195 private ClientCall.Listener<Integer> mockCallListener3;
197 private ClientCall.Listener<Integer> mockCallListener4;
199 private ClientCall.Listener<Integer> mockCallListener5;
301 ClientCall<String, Integer> call = in immediateDeadlineExceeded()
459 ClientCall<String, Integer> call = channel.newCall(method, CallOptions.DEFAULT); in subtestCallsAndShutdown()
468 ClientCall<String, Integer> call2 = channel.newCall(method, CallOptions.DEFAULT); in subtestCallsAndShutdown()
490 ClientCall<String, Integer> call3 = channel.newCall(method, CallOptions.DEFAULT); in subtestCallsAndShutdown()
[all …]
DManagedChannelOrphanWrapperTest.java25 import io.grpc.ClientCall;
132 public <RequestT, ResponseT> ClientCall<RequestT, ResponseT> newCall( in newCall()
/external/grpc-grpc-java/examples/src/test/java/io/grpc/examples/header/
DHeaderServerInterceptorTest.java27 import io.grpc.ClientCall;
92 ClientCall.Listener<?> spyListener; in serverHeaderDeliveredToClient()
95 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in serverHeaderDeliveredToClient()
101 mock(ClientCall.Listener.class, delegatesTo(responseListener)); in serverHeaderDeliveredToClient()
/external/grpc-grpc-java/services/src/test/java/io/grpc/services/
DBinaryLogProviderTest.java28 import io.grpc.ClientCall;
104 public <RequestT, ResponseT> ClientCall<RequestT, ResponseT> newCall( in wrapChannel_methodDescriptor()
116 ClientCall<String, Integer> unusedClientCall = wChannel.newCall(method, CallOptions.DEFAULT); in wrapChannel_methodDescriptor()
123 final AtomicReference<ClientCall.Listener<?>> listener = in wrapChannel_handler()
124 new AtomicReference<ClientCall.Listener<?>>(); in wrapChannel_handler()
127 public <RequestT, ResponseT> ClientCall<RequestT, ResponseT> newCall( in wrapChannel_handler()
148 ClientCall<String, Integer> clientCall = wChannel.newCall(method, CallOptions.DEFAULT); in wrapChannel_handler()
193 private static void onClientMessageHelper(ClientCall.Listener listener, Object request) { in onClientMessageHelper()
306 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in interceptCall()
DBinlogHelperTest.java49 import io.grpc.ClientCall;
983 ClientCall.Listener<byte[]> mockListener = mock(ClientCall.Listener.class); in clientDeadlineLogged_deadlineSetViaCallOption()
985 ClientCall<byte[], byte[]> call = in clientDeadlineLogged_deadlineSetViaCallOption()
993 public <RequestT, ResponseT> ClientCall<RequestT, ResponseT> newCall( in clientDeadlineLogged_deadlineSetViaCallOption()
1024 final SettableFuture<ClientCall<byte[], byte[]>> callFuture = SettableFuture.create(); in clientDeadlineLogged_deadlineSetViaContext()
1046 public <RequestT, ResponseT> ClientCall<RequestT, ResponseT> newCall( in clientDeadlineLogged_deadlineSetViaContext()
1059 ClientCall.Listener<byte[]> mockListener = mock(ClientCall.Listener.class); in clientDeadlineLogged_deadlineSetViaContext()
1079 final AtomicReference<ClientCall.Listener> interceptedListener = in clientInterceptor()
1080 new AtomicReference<ClientCall.Listener>(); in clientInterceptor()
1089 public <RequestT, ResponseT> ClientCall<RequestT, ResponseT> newCall( in clientInterceptor()
[all …]
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/header/
DHeaderClientInterceptor.java22 import io.grpc.ClientCall;
42 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(MethodDescriptor<ReqT, RespT> method, in interceptCall()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DForwardingManagedChannel.java21 import io.grpc.ClientCall;
61 public <RequestT, ResponseT> ClientCall<RequestT, ResponseT> newCall( in newCall()
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/errorhandling/
DErrorHandlingClient.java27 import io.grpc.ClientCall;
179 ClientCall<HelloRequest, HelloReply> call = in advancedAsyncCall()
184 call.start(new ClientCall.Listener<HelloReply>() { in advancedAsyncCall()
DDetailErrorSample.java29 import io.grpc.ClientCall;
200 ClientCall<HelloRequest, HelloReply> call = in advancedAsyncCall()
205 call.start(new ClientCall.Listener<HelloReply>() { in advancedAsyncCall()
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/stub/
DStubConfigTest.java30 import io.grpc.ClientCall;
62 ClientCall<SimpleRequest, SimpleResponse> call = in setUp()

123