You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@dubbo.apache.org by al...@apache.org on 2022/08/16 08:34:55 UTC

[dubbo-samples] branch master updated: Revert "Add integration test for unary call with StreamObserver (#486)" (#497)

This is an automated email from the ASF dual-hosted git repository.

albumenj pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/dubbo-samples.git


The following commit(s) were added to refs/heads/master by this push:
     new f17c34b3 Revert "Add integration test for unary call with StreamObserver (#486)" (#497)
f17c34b3 is described below

commit f17c34b387145b0aa2ab3bd47d4d1f666bbfbbc6
Author: Albumen Kevin <jh...@gmail.com>
AuthorDate: Tue Aug 16 16:34:50 2022 +0800

    Revert "Add integration test for unary call with StreamObserver (#486)" (#497)
    
    This reverts commit 035220358410a9b26349e8e102a92b417c9e90b1.
---
 .../java/org/apache/dubbo/sample/tri/BaseClientTest.java   | 14 --------------
 1 file changed, 14 deletions(-)

diff --git a/dubbo-samples-triple/src/test/java/org/apache/dubbo/sample/tri/BaseClientTest.java b/dubbo-samples-triple/src/test/java/org/apache/dubbo/sample/tri/BaseClientTest.java
index 884eeb32..b4256738 100644
--- a/dubbo-samples-triple/src/test/java/org/apache/dubbo/sample/tri/BaseClientTest.java
+++ b/dubbo-samples-triple/src/test/java/org/apache/dubbo/sample/tri/BaseClientTest.java
@@ -299,20 +299,6 @@ public abstract class BaseClientTest {
         Assert.assertNotNull(reply);
     }
 
-    @Test
-    public void unaryGreeterWithStream() throws InterruptedException {
-        CountDownLatch latch = new CountDownLatch(1);
-        delegate.greet(GreeterRequest.newBuilder()
-                .setName("name")
-                .build(), new StdoutStreamObserver<GreeterReply>("unaryGreeterWithStream") {
-            @Override
-            public void onNext(GreeterReply data) {
-                super.onNext(data);
-                latch.countDown();
-            }
-        });
-        Assert.assertTrue(latch.await(3, TimeUnit.SECONDS));
-    }
 
     @Test(expected = RpcException.class)
     public void clientSendLargeSizeHeader() {


---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@dubbo.apache.org
For additional commands, e-mail: notifications-help@dubbo.apache.org