This is an automated email from the ASF dual-hosted git repository.
guohao 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 93f9b1b Fix onNext error after cancel
new d7e8eac Merge pull request #422 from guohao/fix-server-stream-cancel
93f9b1b is described below
commit 93f9b1b61da58cdf09acef556bdd9ede07c6eeed
Author: guohao <[email protected]>
AuthorDate: Tue Feb 15 12:00:48 2022 +0800
Fix onNext error after cancel
---
.../test/java/org/apache/dubbo/sample/tri/BasePbConsumerTest.java | 7 ++-----
1 file changed, 2 insertions(+), 5 deletions(-)
diff --git
a/dubbo-samples-triple/src/test/java/org/apache/dubbo/sample/tri/BasePbConsumerTest.java
b/dubbo-samples-triple/src/test/java/org/apache/dubbo/sample/tri/BasePbConsumerTest.java
index fbdaa44..dfb2c26 100644
---
a/dubbo-samples-triple/src/test/java/org/apache/dubbo/sample/tri/BasePbConsumerTest.java
+++
b/dubbo-samples-triple/src/test/java/org/apache/dubbo/sample/tri/BasePbConsumerTest.java
@@ -85,7 +85,6 @@ public abstract class BasePbConsumerTest {
@Test
public void cancelBiStream() throws InterruptedException {
- int n = 10;
final GreeterRequest request = GreeterRequest.newBuilder()
.setName("stream request")
.build();
@@ -110,10 +109,8 @@ public abstract class BasePbConsumerTest {
delegateManual.cancelBiStream(observer);
CancelableStreamObserver<GreeterRequest> streamObserver =
(CancelableStreamObserver<GreeterRequest>) requestObserver;
- for (int i = 0; i < n; i++) {
- streamObserver.onNext(request);
- streamObserver.cancel(new RuntimeException());
- }
+ streamObserver.onNext(request);
+ streamObserver.cancel(new RuntimeException());
streamObserver.onCompleted();
Thread.sleep(2000);
GreeterReply reply = delegateManual.queryCancelResult(
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
