|
76 | 76 | import java.util.HashSet; |
77 | 77 | import java.util.List; |
78 | 78 | import java.util.Set; |
79 | | -import java.util.concurrent.CountDownLatch; |
80 | | -import java.util.concurrent.TimeUnit; |
81 | 79 |
|
82 | 80 | /** |
83 | 81 | * Tests for {@link ProtoReflectionService}. |
@@ -109,10 +107,6 @@ public void setUp() throws Exception { |
109 | 107 | .directExecutor() |
110 | 108 | .build(); |
111 | 109 | stub = ServerReflectionGrpc.newStub(channel); |
112 | | - |
113 | | - // TODO(ericgribkoff) Remove after fix for https://github.com/grpc/grpc-java/issues/2444 is |
114 | | - // merged. |
115 | | - doNoOpCall(); |
116 | 110 | } |
117 | 111 |
|
118 | 112 | @After |
@@ -606,31 +600,4 @@ private void assertServiceResponseEquals(Set<ServiceResponse> goldenResponse) th |
606 | 600 | assertEquals(goldenResponse.size(), response.size()); |
607 | 601 | assertEquals(goldenResponse, new HashSet<ServiceResponse>(response)); |
608 | 602 | } |
609 | | - |
610 | | - // TODO(ericgribkoff) Remove after fix for https://github.com/grpc/grpc-java/issues/2444 is |
611 | | - // merged. |
612 | | - private void doNoOpCall() throws Exception { |
613 | | - final CountDownLatch latch = new CountDownLatch(1); |
614 | | - ServerReflectionRequest request = |
615 | | - ServerReflectionRequest.newBuilder().setHost(TEST_HOST).setListServices("services").build(); |
616 | | - StreamObserver<ServerReflectionRequest> requestObserver = |
617 | | - stub.serverReflectionInfo(new StreamObserver<ServerReflectionResponse>() { |
618 | | - @Override |
619 | | - public void onNext(ServerReflectionResponse value) { |
620 | | - } |
621 | | - |
622 | | - @Override |
623 | | - public void onError(Throwable t) { |
624 | | - latch.countDown(); |
625 | | - } |
626 | | - |
627 | | - @Override |
628 | | - public void onCompleted() { |
629 | | - latch.countDown(); |
630 | | - } |
631 | | - }); |
632 | | - requestObserver.onNext(request); |
633 | | - requestObserver.onCompleted(); |
634 | | - assertTrue(latch.await(5, TimeUnit.SECONDS)); |
635 | | - } |
636 | 603 | } |
0 commit comments