flasn4nt
/
grpc-java
mirror of https://github.com/grpc/grpc-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

stub: remove a reference to internal

This commit is contained in:
Carl Mastrangelo 2016-12-02 09:13:37 -08:00 committed by GitHub
parent 4d4d4b386e
commit f15ed05260
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
benchmarks/src/test/java/io/grpc/benchmarks/driver/LoadWorkerTest.java
View File

@ -34,11 +34,11 @@ package io.grpc.benchmarks.driver;
import static org.junit.Assert.assertTrue; import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail; import static org.junit.Assert.fail;
import io.grpc.ManagedChannel;
import io.grpc.benchmarks.Utils; import io.grpc.benchmarks.Utils;
import io.grpc.benchmarks.proto.Control; import io.grpc.benchmarks.proto.Control;
import io.grpc.benchmarks.proto.Stats; import io.grpc.benchmarks.proto.Stats;
import io.grpc.benchmarks.proto.WorkerServiceGrpc; import io.grpc.benchmarks.proto.WorkerServiceGrpc;
import io.grpc.internal.ManagedChannelImpl;
import io.grpc.netty.NettyChannelBuilder; import io.grpc.netty.NettyChannelBuilder;
import io.grpc.stub.StreamObserver; import io.grpc.stub.StreamObserver;
@ -65,7 +65,7 @@ public class LoadWorkerTest {
.build(); .build();
private LoadWorker worker; private LoadWorker worker;
private ManagedChannelImpl channel; private ManagedChannel channel;
private WorkerServiceGrpc.WorkerServiceStub workerServiceStub; private WorkerServiceGrpc.WorkerServiceStub workerServiceStub;
private LinkedBlockingQueue<Stats.ClientStats> marksQueue; private LinkedBlockingQueue<Stats.ClientStats> marksQueue;

4
stub/src/test/java/io/grpc/stub/ServerCallsTest.java
View File

@ -40,6 +40,7 @@ import static org.junit.Assert.fail;
import io.grpc.CallOptions; import io.grpc.CallOptions;
import io.grpc.ClientCall; import io.grpc.ClientCall;
import io.grpc.ManagedChannel;
import io.grpc.Metadata; import io.grpc.Metadata;
import io.grpc.MethodDescriptor; import io.grpc.MethodDescriptor;
import io.grpc.ServerCall; import io.grpc.ServerCall;
@ -49,7 +50,6 @@ import io.grpc.ServiceDescriptor;
import io.grpc.Status; import io.grpc.Status;
import io.grpc.inprocess.InProcessChannelBuilder; import io.grpc.inprocess.InProcessChannelBuilder;
import io.grpc.inprocess.InProcessServerBuilder; import io.grpc.inprocess.InProcessServerBuilder;
import io.grpc.internal.ManagedChannelImpl;
import org.junit.Test; import org.junit.Test;
import org.junit.runner.RunWith; import org.junit.runner.RunWith;
@ -332,7 +332,7 @@ public class ServerCallsTest {
.build(); .build();
long tag = System.nanoTime(); long tag = System.nanoTime();
InProcessServerBuilder.forName("go-with-the-flow" + tag).addService(service).build().start(); InProcessServerBuilder.forName("go-with-the-flow" + tag).addService(service).build().start();
ManagedChannelImpl channel = InProcessChannelBuilder.forName("go-with-the-flow" + tag).build(); ManagedChannel channel = InProcessChannelBuilder.forName("go-with-the-flow" + tag).build();
final ClientCall<Integer, Integer> clientCall = channel.newCall(STREAMING_METHOD, final ClientCall<Integer, Integer> clientCall = channel.newCall(STREAMING_METHOD,
CallOptions.DEFAULT); CallOptions.DEFAULT);
final CountDownLatch latch = new CountDownLatch(1); final CountDownLatch latch = new CountDownLatch(1);