aboutsummaryrefslogtreecommitdiff
path: root/testing
diff options
context:
space:
mode:
authorKun Zhang <zhangkun83@users.noreply.github.com>2018-01-29 13:42:14 -0800
committerGitHub <noreply@github.com>2018-01-29 13:42:14 -0800
commitdf65bef881de80f2d77cca4eabba3454695edbaa (patch)
tree417b0267f732e8ce44444655d38c8354b7eb3484 /testing
parent0465bb5aeba7ec6aebd3f3a2a8149c3be8b761c9 (diff)
downloadgrpc-grpc-java-df65bef881de80f2d77cca4eabba3454695edbaa.tar.gz
core: delete outboundMessage() and inboundMessage() on StreamTracer. (#4014)
They were deprecated in 1.7.0.
Diffstat (limited to 'testing')
-rw-r--r--testing/src/main/java/io/grpc/internal/testing/AbstractTransportTest.java4
-rw-r--r--testing/src/main/java/io/grpc/internal/testing/TestClientStreamTracer.java12
-rw-r--r--testing/src/main/java/io/grpc/internal/testing/TestServerStreamTracer.java12
-rw-r--r--testing/src/main/java/io/grpc/internal/testing/TestStreamTracer.java12
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 + ")");
}