diff --git a/core/src/main/java/io/grpc/internal/ServerCallImpl.java b/core/src/main/java/io/grpc/internal/ServerCallImpl.java index 290c9c310f..8ff60f4375 100644 --- a/core/src/main/java/io/grpc/internal/ServerCallImpl.java +++ b/core/src/main/java/io/grpc/internal/ServerCallImpl.java @@ -45,9 +45,9 @@ final class ServerCallImpl extends ServerCall { private static final Logger log = Logger.getLogger(ServerCallImpl.class.getName()); @VisibleForTesting - static String TOO_MANY_RESPONSES = "Too many responses"; + static final String TOO_MANY_RESPONSES = "Too many responses"; @VisibleForTesting - static String MISSING_RESPONSE = "Completed without a response"; + static final String MISSING_RESPONSE = "Completed without a response"; private final ServerStream stream; private final MethodDescriptor method; diff --git a/core/src/test/java/io/grpc/internal/AbstractClientStreamTest.java b/core/src/test/java/io/grpc/internal/AbstractClientStreamTest.java index 801cf446f8..badd716516 100644 --- a/core/src/test/java/io/grpc/internal/AbstractClientStreamTest.java +++ b/core/src/test/java/io/grpc/internal/AbstractClientStreamTest.java @@ -27,8 +27,6 @@ import static org.mockito.Mockito.never; import static org.mockito.Mockito.verify; import io.grpc.Attributes; -import io.grpc.CallOptions; -import io.grpc.ClientStreamTracer; import io.grpc.Codec; import io.grpc.Metadata; import io.grpc.Status; @@ -226,14 +224,6 @@ public class AbstractClientStreamTest { public void getRequest() { AbstractClientStream.Sink sink = mock(AbstractClientStream.Sink.class); final TestClientStreamTracer tracer = new TestClientStreamTracer(); - ClientStreamTracer.Factory tracerFactory = - new ClientStreamTracer.Factory() { - @Override - public ClientStreamTracer newClientStreamTracer( - CallOptions callOptions, Metadata headers) { - return tracer; - } - }; StatsTraceContext statsTraceCtx = new StatsTraceContext(new StreamTracer[] {tracer}); AbstractClientStream stream = new BaseAbstractClientStream(allocator, new BaseTransportState(statsTraceCtx), sink, statsTraceCtx, true); diff --git a/core/src/test/java/io/grpc/internal/MessageDeframerTest.java b/core/src/test/java/io/grpc/internal/MessageDeframerTest.java index bd140d98a7..f0eb14a662 100644 --- a/core/src/test/java/io/grpc/internal/MessageDeframerTest.java +++ b/core/src/test/java/io/grpc/internal/MessageDeframerTest.java @@ -62,8 +62,6 @@ public class MessageDeframerTest { private Listener listener = mock(Listener.class); private TestBaseStreamTracer tracer = new TestBaseStreamTracer(); private StatsTraceContext statsTraceCtx = new StatsTraceContext(new StreamTracer[]{tracer}); - private ArgumentCaptor wireSizeCaptor = ArgumentCaptor.forClass(Long.class); - private ArgumentCaptor uncompressedSizeCaptor = ArgumentCaptor.forClass(Long.class); private MessageDeframer deframer = new MessageDeframer(listener, Codec.Identity.NONE, DEFAULT_MAX_MESSAGE_SIZE, statsTraceCtx, "test"); @@ -397,10 +395,6 @@ public class MessageDeframerTest { assertEquals(uncompressedBytesReceived, tracer.getInboundUncompressedSize()); } - private static List bytes(ArgumentCaptor captor) { - return bytes(captor.getValue()); - } - private static List bytes(InputStream in) { try { return Bytes.asList(ByteStreams.toByteArray(in)); diff --git a/protobuf-lite/src/test/java/io/grpc/protobuf/lite/ProtoLiteUtilsTest.java b/protobuf-lite/src/test/java/io/grpc/protobuf/lite/ProtoLiteUtilsTest.java index c4a4d32174..7134a507ab 100644 --- a/protobuf-lite/src/test/java/io/grpc/protobuf/lite/ProtoLiteUtilsTest.java +++ b/protobuf-lite/src/test/java/io/grpc/protobuf/lite/ProtoLiteUtilsTest.java @@ -180,7 +180,6 @@ public class ProtoLiteUtilsTest { @Test public void testDrainTo_none() throws Exception { - byte[] golden = ByteStreams.toByteArray(marshaller.stream(proto)); InputStream is = marshaller.stream(proto); byte[] unused = ByteStreams.toByteArray(is); Drainable d = (Drainable) is;