grpc
/
grpc-java
mirror of https://github.com/grpc/grpc-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

android-interop-testing: fix lint 

fix JavaStyle and ErrorProne warnings found in internal weekly import
This commit is contained in:
ZHANG Dapeng 2017-03-03 16:58:58 -08:00 committed by GitHub
parent 7bb60dc05c
commit acf093dc14
1 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
android-interop-testing/app/src/main/java/io/grpc/android/integrationtest/InteropTester.java
View File

@ -60,7 +60,6 @@ import io.grpc.stub.StreamObserver;
import io.grpc.testing.StreamRecorder; import io.grpc.testing.StreamRecorder;
import java.io.PrintWriter; import java.io.PrintWriter;
import java.io.StringWriter; import java.io.StringWriter;
import java.lang.RuntimeException;
import java.util.Arrays; import java.util.Arrays;
import java.util.List; import java.util.List;
import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.ArrayBlockingQueue;
@ -79,9 +78,10 @@ final class InteropTester extends AsyncTask<Void, Void, String> {
private TestServiceGrpc.TestServiceStub asyncStub; private TestServiceGrpc.TestServiceStub asyncStub;
private String testCase; private String testCase;
private TestListener listener; private TestListener listener;
private static int TIMEOUT_MILLIS = 5000; private static final int TIMEOUT_MILLIS = 5000;
class ResponseObserver implements StreamObserver<Messages.StreamingOutputCallResponse> { private static final class ResponseObserver
implements StreamObserver<Messages.StreamingOutputCallResponse> {
public LinkedBlockingQueue<Object> responses = new LinkedBlockingQueue<Object>(); public LinkedBlockingQueue<Object> responses = new LinkedBlockingQueue<Object>();
final Object magicTailResponse = new Object(); final Object magicTailResponse = new Object();
@ -319,7 +319,6 @@ final class InteropTester extends AsyncTask<Void, Void, String> {
goldenResponses[2].payload.body = new byte[2653]; goldenResponses[2].payload.body = new byte[2653];
goldenResponses[3].payload.body = new byte[58979]; goldenResponses[3].payload.body = new byte[58979];
@SuppressWarnings("unchecked")
ResponseObserver responseObserver = new ResponseObserver(); ResponseObserver responseObserver = new ResponseObserver();
StreamObserver<Messages.StreamingOutputCallRequest> requestObserver StreamObserver<Messages.StreamingOutputCallRequest> requestObserver
= asyncStub.fullDuplexCall(responseObserver); = asyncStub.fullDuplexCall(responseObserver);
@ -339,7 +338,6 @@ final class InteropTester extends AsyncTask<Void, Void, String> {
} }
public void emptyStream() throws Exception { public void emptyStream() throws Exception {
@SuppressWarnings("unchecked")
ResponseObserver responseObserver = new ResponseObserver(); ResponseObserver responseObserver = new ResponseObserver();
StreamObserver<StreamingOutputCallRequest> requestObserver StreamObserver<StreamingOutputCallRequest> requestObserver
= asyncStub.fullDuplexCall(responseObserver); = asyncStub.fullDuplexCall(responseObserver);