|
28 | 28 | import io.grpc.ManagedChannelProvider; |
29 | 29 | import io.grpc.ManagedChannelProvider.NewChannelBuilderResult; |
30 | 30 | import io.grpc.ManagedChannelRegistryAccessor; |
31 | | -import io.grpc.NameResolverRegistry; |
32 | 31 | import io.grpc.TlsChannelCredentials; |
33 | | -import io.grpc.internal.testing.FakeNameResolverProvider; |
34 | 32 | import io.grpc.stub.StreamObserver; |
35 | 33 | import io.grpc.testing.GrpcCleanupRule; |
36 | 34 | import io.grpc.testing.protobuf.SimpleRequest; |
@@ -122,24 +120,6 @@ public void managedChannelRegistry_newChannelBuilder() { |
122 | 120 | channel.shutdownNow(); |
123 | 121 | } |
124 | 122 |
|
125 | | - @Test |
126 | | - public void managedChannelRegistry_newChannelBuilderForNameResolverRegistry() { |
127 | | - Assume.assumeTrue(Utils.isEpollAvailable()); |
128 | | - NameResolverRegistry nameResolverRegistry = new NameResolverRegistry(); |
129 | | - DomainSocketAddress socketAddress = new DomainSocketAddress("test-server"); |
130 | | - FakeNameResolverProvider fakeNameResolverProvider = new FakeNameResolverProvider( |
131 | | - "unix:///sock.sock", socketAddress); |
132 | | - nameResolverRegistry.register(fakeNameResolverProvider); |
133 | | - ManagedChannelBuilder<?> managedChannelBuilder |
134 | | - = Grpc.newChannelBuilder("unix:///sock.sock", |
135 | | - InsecureChannelCredentials.create(), nameResolverRegistry); |
136 | | - assertThat(managedChannelBuilder).isNotNull(); |
137 | | - ManagedChannel channel = managedChannelBuilder.build(); |
138 | | - assertThat(channel).isNotNull(); |
139 | | - assertThat(channel.authority()).isEqualTo("/sock.sock"); |
140 | | - channel.shutdownNow(); |
141 | | - } |
142 | | - |
143 | 123 | @Test |
144 | 124 | public void udsClientServerTestUsingProvider() throws IOException { |
145 | 125 | Assume.assumeTrue(Utils.isEpollAvailable()); |
|
0 commit comments