all: fix lint
diff --git a/core/src/main/java/io/grpc/internal/ClientCallImpl.java b/core/src/main/java/io/grpc/internal/ClientCallImpl.java
index 9248f9c..6f1bd12 100644
--- a/core/src/main/java/io/grpc/internal/ClientCallImpl.java
+++ b/core/src/main/java/io/grpc/internal/ClientCallImpl.java
@@ -202,7 +202,7 @@
return;
}
final String compressorName = callOptions.getCompressor();
- Compressor compressor = null;
+ Compressor compressor;
if (compressorName != null) {
compressor = compressorRegistry.lookupCompressor(compressorName);
if (compressor == null) {
diff --git a/interop-testing/src/test/java/io/grpc/testing/integration/ProxyTest.java b/interop-testing/src/test/java/io/grpc/testing/integration/ProxyTest.java
index a80835e..c336ee9 100644
--- a/interop-testing/src/test/java/io/grpc/testing/integration/ProxyTest.java
+++ b/interop-testing/src/test/java/io/grpc/testing/integration/ProxyTest.java
@@ -18,6 +18,7 @@
import static org.junit.Assert.assertEquals;
+import com.google.common.io.ByteStreams;
import io.netty.util.concurrent.DefaultThreadFactory;
import java.io.DataInputStream;
import java.io.IOException;
@@ -139,7 +140,6 @@
proxy = new TrafficControlProxy(serverPort, bandwidth, 200, TimeUnit.MILLISECONDS);
proxy.start();
client = new Socket("localhost", proxy.getPort());
- OutputStream clientOut = client.getOutputStream();
DataInputStream clientIn = new DataInputStream(client.getInputStream());
clientIn.readFully(new byte[100 * 1024]);
@@ -167,7 +167,6 @@
proxy = new TrafficControlProxy(serverPort, bandwidth, 200, TimeUnit.MILLISECONDS);
proxy.start();
client = new Socket("localhost", proxy.getPort());
- OutputStream clientOut = client.getOutputStream();
DataInputStream clientIn = new DataInputStream(client.getInputStream());
clientIn.readFully(new byte[100 * 1024]);
@@ -224,11 +223,7 @@
InputStream serverIn = rcv.getInputStream();
OutputStream serverOut = rcv.getOutputStream();
if (mode.equals("echo")) {
- byte[] response = new byte[1024];
- int readable;
- while ((readable = serverIn.read(response)) != -1) {
- serverOut.write(response, 0, readable);
- }
+ ByteStreams.copy(serverIn, serverOut);
} else if (mode.equals("stream")) {
byte[] message = new byte[1024];
while (true) {
