Skip to content

Commit a87f227

Browse files
Oleh DokukaOlegDokuka
Oleh Dokuka
authored andcommitted
fixed memory leak
Signed-off-by: Oleh Dokuka <[email protected]> Signed-off-by: Oleh Dokuka <[email protected]>
1 parent 7e6330d commit a87f227

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

rsocket-core/src/main/java/io/rsocket/internal/UnboundedProcessor.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -124,6 +124,9 @@ void drainRegular(Subscriber<? super T> a) {
124124
}
125125

126126
if (checkTerminated(d, empty, a)) {
127+
if (!empty) {
128+
release(t);
129+
}
127130
return;
128131
}
129132

0 commit comments

Comments
 (0)