Skip to content

Commit ce62903

Browse files
committed
fixes AssertSubscriber to terminate upstream if ASYNC fusion
Signed-off-by: Oleh Dokuka <[email protected]>
1 parent 61652c3 commit ce62903

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

rsocket-core/src/test/java/io/rsocket/internal/subscriber/AssertSubscriber.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -943,6 +943,7 @@ void drain() {
943943
t = qs.poll();
944944
if (t == null) {
945945
if (done) {
946+
qs.clear(); // clear upstream to terminated it due to the contract
946947
cdl.countDown();
947948
return;
948949
}

0 commit comments

Comments
 (0)