fixed memory leak

Signed-off-by: Oleh Dokuka <odokuka@vmware.com> Signed-off-by: Oleh Dokuka <shadowgun@i.ua>
rsocket · Feb 26, 2021 · a87f227 · a87f227
1 parent 7e6330d
commit a87f227
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/rsocket-core/src/main/java/io/rsocket/internal/UnboundedProcessor.java b/rsocket-core/src/main/java/io/rsocket/internal/UnboundedProcessor.java
@@ -124,6 +124,9 @@ void drainRegular(Subscriber<? super T> a) {
         }
 
         if (checkTerminated(d, empty, a)) {
+          if (!empty) {
+            release(t);
+          }
           return;
         }