diff options
author | Kun Zhang <zhangkun@google.com> | 2015-06-04 16:39:25 -0700 |
---|---|---|
committer | Kun Zhang <zhangkun@google.com> | 2015-06-04 16:39:25 -0700 |
commit | 2ee4d0228ddb67a3777146400c82a74d111e3bb8 (patch) | |
tree | 3c36d6acd49c1d1061d9359215d701577526857c /auth | |
parent | 4ee2a6584a2f3a2054654409355b1f7995433b96 (diff) | |
download | grpc-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.java | 8 | ||||
-rw-r--r-- | auth/src/test/java/io/grpc/auth/ClientAuthInterceptorTests.java | 12 |
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); |