aboutsummaryrefslogtreecommitdiff
path: root/auth
diff options
context:
space:
mode:
authorKun Zhang <zhangkun@google.com>2015-06-04 16:39:25 -0700
committerKun Zhang <zhangkun@google.com>2015-06-04 16:39:25 -0700
commit2ee4d0228ddb67a3777146400c82a74d111e3bb8 (patch)
tree3c36d6acd49c1d1061d9359215d701577526857c /auth
parent4ee2a6584a2f3a2054654409355b1f7995433b96 (diff)
downloadgrpc-grpc-java-2ee4d0228ddb67a3777146400c82a74d111e3bb8.tar.gz
Rename Call to ClientCalls.
Other classes are already following the convention that ClientFoo for client-side, and ServerFoo for server-side. Call has been the black sheep of the family. - Call -> ClientCall - Calls -> ClientCalls - ForwardingCall* -> ForwardingClientCall*
Diffstat (limited to 'auth')
-rw-r--r--auth/src/main/java/io/grpc/auth/ClientAuthInterceptor.java8
-rw-r--r--auth/src/test/java/io/grpc/auth/ClientAuthInterceptorTests.java12
2 files changed, 10 insertions, 10 deletions
diff --git a/auth/src/main/java/io/grpc/auth/ClientAuthInterceptor.java b/auth/src/main/java/io/grpc/auth/ClientAuthInterceptor.java
index a9699ea77..2af4b1be8 100644
--- a/auth/src/main/java/io/grpc/auth/ClientAuthInterceptor.java
+++ b/auth/src/main/java/io/grpc/auth/ClientAuthInterceptor.java
@@ -34,10 +34,10 @@ package io.grpc.auth;
import com.google.auth.Credentials;
import com.google.common.base.Preconditions;
-import io.grpc.Call;
import io.grpc.Channel;
+import io.grpc.ClientCall;
import io.grpc.ClientInterceptor;
-import io.grpc.ClientInterceptors.CheckedForwardingCall;
+import io.grpc.ClientInterceptors.CheckedForwardingClientCall;
import io.grpc.Metadata;
import io.grpc.MethodDescriptor;
@@ -64,11 +64,11 @@ public class ClientAuthInterceptor implements ClientInterceptor {
}
@Override
- public <ReqT, RespT> Call<ReqT, RespT> interceptCall(MethodDescriptor<ReqT, RespT> method,
+ public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(MethodDescriptor<ReqT, RespT> method,
Channel next) {
// TODO(ejona86): If the call fails for Auth reasons, this does not properly propagate info that
// would be in WWW-Authenticate, because it does not yet have access to the header.
- return new CheckedForwardingCall<ReqT, RespT>(next.newCall(method)) {
+ return new CheckedForwardingClientCall<ReqT, RespT>(next.newCall(method)) {
@Override
protected void checkedStart(Listener<RespT> responseListener, Metadata.Headers headers)
throws Exception {
diff --git a/auth/src/test/java/io/grpc/auth/ClientAuthInterceptorTests.java b/auth/src/test/java/io/grpc/auth/ClientAuthInterceptorTests.java
index 7578f3fe1..8fe7f84c8 100644
--- a/auth/src/test/java/io/grpc/auth/ClientAuthInterceptorTests.java
+++ b/auth/src/test/java/io/grpc/auth/ClientAuthInterceptorTests.java
@@ -44,8 +44,8 @@ import com.google.common.collect.LinkedListMultimap;
import com.google.common.collect.ListMultimap;
import com.google.common.collect.Multimaps;
-import io.grpc.Call;
import io.grpc.Channel;
+import io.grpc.ClientCall;
import io.grpc.Metadata;
import io.grpc.MethodDescriptor;
import io.grpc.Status;
@@ -82,13 +82,13 @@ public class ClientAuthInterceptorTests {
MethodDescriptor<String, Integer> descriptor;
@Mock
- Call.Listener<Integer> listener;
+ ClientCall.Listener<Integer> listener;
@Mock
Channel channel;
@Mock
- Call<String, Integer> call;
+ ClientCall<String, Integer> call;
ClientAuthInterceptor interceptor;
@@ -109,7 +109,7 @@ public class ClientAuthInterceptorTests {
values.put("Extra-Authorization", "token3");
values.put("Extra-Authorization", "token4");
when(credentials.getRequestMetadata()).thenReturn(Multimaps.asMap(values));
- Call<String, Integer> interceptedCall = interceptor.interceptCall(descriptor, channel);
+ ClientCall<String, Integer> interceptedCall = interceptor.interceptCall(descriptor, channel);
Metadata.Headers headers = new Metadata.Headers();
interceptedCall.start(listener, headers);
verify(call).start(listener, headers);
@@ -125,7 +125,7 @@ public class ClientAuthInterceptorTests {
@Test
public void testCredentialsThrows() throws IOException {
when(credentials.getRequestMetadata()).thenThrow(new IOException("Broken"));
- Call<String, Integer> interceptedCall = interceptor.interceptCall(descriptor, channel);
+ ClientCall<String, Integer> interceptedCall = interceptor.interceptCall(descriptor, channel);
Metadata.Headers headers = new Metadata.Headers();
interceptedCall.start(listener, headers);
ArgumentCaptor<Status> statusCaptor = ArgumentCaptor.forClass(Status.class);
@@ -146,7 +146,7 @@ public class ClientAuthInterceptorTests {
}
};
interceptor = new ClientAuthInterceptor(oAuth2Credentials, Executors.newSingleThreadExecutor());
- Call<String, Integer> interceptedCall = interceptor.interceptCall(descriptor, channel);
+ ClientCall<String, Integer> interceptedCall = interceptor.interceptCall(descriptor, channel);
Metadata.Headers headers = new Metadata.Headers();
interceptedCall.start(listener, headers);
verify(call).start(listener, headers);