diff options
author | Kun Zhang <zhangkun83@users.noreply.github.com> | 2018-01-29 13:42:14 -0800 |
---|---|---|
committer | GitHub <noreply@github.com> | 2018-01-29 13:42:14 -0800 |
commit | df65bef881de80f2d77cca4eabba3454695edbaa (patch) | |
tree | 417b0267f732e8ce44444655d38c8354b7eb3484 /testing | |
parent | 0465bb5aeba7ec6aebd3f3a2a8149c3be8b761c9 (diff) | |
download | grpc-grpc-java-df65bef881de80f2d77cca4eabba3454695edbaa.tar.gz |
core: delete outboundMessage() and inboundMessage() on StreamTracer. (#4014)
They were deprecated in 1.7.0.
Diffstat (limited to 'testing')
4 files changed, 0 insertions, 40 deletions
diff --git a/testing/src/main/java/io/grpc/internal/testing/AbstractTransportTest.java b/testing/src/main/java/io/grpc/internal/testing/AbstractTransportTest.java index 0af6b761a..111c9c3b4 100644 --- a/testing/src/main/java/io/grpc/internal/testing/AbstractTransportTest.java +++ b/testing/src/main/java/io/grpc/internal/testing/AbstractTransportTest.java @@ -685,7 +685,6 @@ public abstract class AbstractTransportTest { assertTrue(clientStream.isReady()); clientStream.writeMessage(methodDescriptor.streamRequest("Hello!")); assertThat(clientStreamTracer1.nextOutboundEvent()).isEqualTo("outboundMessage(0)"); - assertThat(clientStreamTracer1.nextOutboundEvent()).isEqualTo("outboundMessage()"); clientStream.flush(); InputStream message = serverStreamListener.messageQueue.poll(TIMEOUT_MS, TimeUnit.MILLISECONDS); @@ -701,7 +700,6 @@ public abstract class AbstractTransportTest { assertThat(clientStreamTracer1.getOutboundUncompressedSize()).isEqualTo(0L); } assertThat(serverStreamTracer1.nextInboundEvent()).isEqualTo("inboundMessage(0)"); - assertThat(serverStreamTracer1.nextInboundEvent()).isEqualTo("inboundMessage()"); assertNull("no additional message expected", serverStreamListener.messageQueue.poll()); clientStream.halfClose(); @@ -739,7 +737,6 @@ public abstract class AbstractTransportTest { assertTrue(serverStream.isReady()); serverStream.writeMessage(methodDescriptor.streamResponse("Hi. Who are you?")); assertThat(serverStreamTracer1.nextOutboundEvent()).isEqualTo("outboundMessage(0)"); - assertThat(serverStreamTracer1.nextOutboundEvent()).isEqualTo("outboundMessage()"); serverStream.flush(); message = clientStreamListener.messageQueue.poll(TIMEOUT_MS, TimeUnit.MILLISECONDS); @@ -755,7 +752,6 @@ public abstract class AbstractTransportTest { } assertTrue(clientStreamTracer1.getInboundHeaders()); assertThat(clientStreamTracer1.nextInboundEvent()).isEqualTo("inboundMessage(0)"); - assertThat(clientStreamTracer1.nextInboundEvent()).isEqualTo("inboundMessage()"); assertEquals("Hi. Who are you?", methodDescriptor.parseResponse(message)); assertThat(clientStreamTracer1.nextInboundEvent()) .matches("inboundMessageRead\\(0, -?[0-9]+, -?[0-9]+\\)"); diff --git a/testing/src/main/java/io/grpc/internal/testing/TestClientStreamTracer.java b/testing/src/main/java/io/grpc/internal/testing/TestClientStreamTracer.java index b31bf49fd..b98272f5e 100644 --- a/testing/src/main/java/io/grpc/internal/testing/TestClientStreamTracer.java +++ b/testing/src/main/java/io/grpc/internal/testing/TestClientStreamTracer.java @@ -133,23 +133,11 @@ public class TestClientStreamTracer extends ClientStreamTracer implements TestSt } @Override - @SuppressWarnings("deprecation") - public void inboundMessage() { - delegate.inboundMessage(); - } - - @Override public void inboundMessage(int seqNo) { delegate.inboundMessage(seqNo); } @Override - @SuppressWarnings("deprecation") - public void outboundMessage() { - delegate.outboundMessage(); - } - - @Override public void outboundMessage(int seqNo) { delegate.outboundMessage(seqNo); } diff --git a/testing/src/main/java/io/grpc/internal/testing/TestServerStreamTracer.java b/testing/src/main/java/io/grpc/internal/testing/TestServerStreamTracer.java index a7c347a47..c04c8ac92 100644 --- a/testing/src/main/java/io/grpc/internal/testing/TestServerStreamTracer.java +++ b/testing/src/main/java/io/grpc/internal/testing/TestServerStreamTracer.java @@ -112,23 +112,11 @@ public class TestServerStreamTracer extends ServerStreamTracer implements TestSt } @Override - @SuppressWarnings("deprecation") - public void inboundMessage() { - delegate.inboundMessage(); - } - - @Override public void inboundMessage(int seqNo) { delegate.inboundMessage(seqNo); } @Override - @SuppressWarnings("deprecation") - public void outboundMessage() { - delegate.outboundMessage(); - } - - @Override public void outboundMessage(int seqNo) { delegate.outboundMessage(seqNo); } diff --git a/testing/src/main/java/io/grpc/internal/testing/TestStreamTracer.java b/testing/src/main/java/io/grpc/internal/testing/TestStreamTracer.java index a017914d0..21252852b 100644 --- a/testing/src/main/java/io/grpc/internal/testing/TestStreamTracer.java +++ b/testing/src/main/java/io/grpc/internal/testing/TestStreamTracer.java @@ -164,23 +164,11 @@ public interface TestStreamTracer { } @Override - @SuppressWarnings("deprecation") - public void inboundMessage() { - inboundEvents.add("inboundMessage()"); - } - - @Override public void inboundMessage(int seqNo) { inboundEvents.add("inboundMessage(" + seqNo + ")"); } @Override - @SuppressWarnings("deprecation") - public void outboundMessage() { - outboundEvents.add("outboundMessage()"); - } - - @Override public void outboundMessage(int seqNo) { outboundEvents.add("outboundMessage(" + seqNo + ")"); } |