diff --git a/core/src/main/java/io/grpc/inprocess/InProcessServer.java b/core/src/main/java/io/grpc/inprocess/InProcessServer.java index 98a99516d1..0dabae7148 100644 --- a/core/src/main/java/io/grpc/inprocess/InProcessServer.java +++ b/core/src/main/java/io/grpc/inprocess/InProcessServer.java @@ -31,9 +31,9 @@ package io.grpc.inprocess; +import io.grpc.internal.InternalServer; import io.grpc.internal.ServerListener; import io.grpc.internal.ServerTransportListener; -import io.grpc.internal.TransportServer; import java.io.IOException; import java.util.concurrent.ConcurrentHashMap; @@ -42,7 +42,7 @@ import java.util.concurrent.ConcurrentMap; import javax.annotation.concurrent.ThreadSafe; @ThreadSafe -class InProcessServer implements TransportServer { +class InProcessServer implements InternalServer { private static final ConcurrentMap registry = new ConcurrentHashMap(); diff --git a/core/src/main/java/io/grpc/internal/AbstractServerImplBuilder.java b/core/src/main/java/io/grpc/internal/AbstractServerImplBuilder.java index c700e452f7..0f528abd37 100644 --- a/core/src/main/java/io/grpc/internal/AbstractServerImplBuilder.java +++ b/core/src/main/java/io/grpc/internal/AbstractServerImplBuilder.java @@ -138,7 +138,7 @@ public abstract class AbstractServerImplBuilder channelType; diff --git a/netty/src/test/java/io/grpc/netty/NettyTransportTest.java b/netty/src/test/java/io/grpc/netty/NettyTransportTest.java index 7b23ec70fa..b50cab77a7 100644 --- a/netty/src/test/java/io/grpc/netty/NettyTransportTest.java +++ b/netty/src/test/java/io/grpc/netty/NettyTransportTest.java @@ -32,8 +32,8 @@ package io.grpc.netty; import io.grpc.internal.ClientTransportFactory; +import io.grpc.internal.InternalServer; import io.grpc.internal.ManagedClientTransport; -import io.grpc.internal.TransportServer; import io.grpc.internal.testing.AbstractTransportTest; import io.grpc.testing.TestUtils; @@ -65,7 +65,7 @@ public class NettyTransportTest extends AbstractTransportTest { } @Override - protected TransportServer newServer() { + protected InternalServer newServer() { return NettyServerBuilder .forPort(SERVER_PORT) .flowControlWindow(65 * 1024) 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 e1a5488434..a011254c22 100644 --- a/testing/src/main/java/io/grpc/internal/testing/AbstractTransportTest.java +++ b/testing/src/main/java/io/grpc/internal/testing/AbstractTransportTest.java @@ -58,13 +58,13 @@ import io.grpc.Status; import io.grpc.internal.ClientStream; import io.grpc.internal.ClientStreamListener; import io.grpc.internal.ClientTransport; +import io.grpc.internal.InternalServer; import io.grpc.internal.ManagedClientTransport; import io.grpc.internal.ServerListener; import io.grpc.internal.ServerStream; import io.grpc.internal.ServerStreamListener; import io.grpc.internal.ServerTransport; import io.grpc.internal.ServerTransportListener; -import io.grpc.internal.TransportServer; import org.junit.After; import org.junit.Before; @@ -99,7 +99,7 @@ public abstract class AbstractTransportTest { * returned instance should be new and yet be accessible by new client transports. This * effectively means that each instance should listen on the same port, or similar. */ - protected abstract TransportServer newServer(); + protected abstract InternalServer newServer(); /** * Returns a new transport that when started will be able to connect to the server. @@ -111,7 +111,7 @@ public abstract class AbstractTransportTest { * {@code serverListener}, otherwise tearDown() can't wait for shutdown which can put following * tests in an indeterminate state. */ - private TransportServer server; + private InternalServer server; private ServerTransport serverTransport; private ManagedClientTransport client; private MethodDescriptor methodDescriptor = MethodDescriptor.create( @@ -215,7 +215,7 @@ public abstract class AbstractTransportTest { public void serverAlreadyListening() throws Exception { client = null; server.start(serverListener); - TransportServer server2 = newServer(); + InternalServer server2 = newServer(); thrown.expect(IOException.class); server2.start(new MockServerListener()); }