From ce62903f3fe6ae16a75aec205cd6ace197b47e36 Mon Sep 17 00:00:00 2001
From: Oleh Dokuka <shadowgun@i.ua>
Date: Sat, 27 Feb 2021 21:06:19 +0200
Subject: [PATCH] fixes AssertSubscriber to terminate upstream if ASYNC fusion

Signed-off-by: Oleh Dokuka <shadowgun@i.ua>
---
 .../java/io/rsocket/internal/subscriber/AssertSubscriber.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git a/rsocket-core/src/test/java/io/rsocket/internal/subscriber/AssertSubscriber.java b/rsocket-core/src/test/java/io/rsocket/internal/subscriber/AssertSubscriber.java
index 83d420d90..28206b4ff 100644
--- a/rsocket-core/src/test/java/io/rsocket/internal/subscriber/AssertSubscriber.java
+++ b/rsocket-core/src/test/java/io/rsocket/internal/subscriber/AssertSubscriber.java
@@ -943,6 +943,7 @@ void drain() {
       t = qs.poll();
       if (t == null) {
         if (done) {
+          qs.clear(); // clear upstream to terminated it due to the contract
           cdl.countDown();
           return;
         }