Skip to content

Commit 0fe0995

Browse files
committed
fix release first
Signed-off-by: Oleh Dokuka <oleh@netifi.com>
1 parent 5e00f4f commit 0fe0995

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -243,14 +243,14 @@ boolean drainRegular() {
243243
for (; ; ) {
244244
if (f != null) {
245245
first = null;
246-
ReferenceCountUtil.safeRelease(f);
247246

248247
if (s == Operators.cancelledSubscription()) {
249248
Operators.onNextDropped(f, a.currentContext());
250249
return true;
251250
}
252251

253252
a.onNext(f);
253+
ReferenceCountUtil.safeRelease(f);
254254
f = null;
255255
sent = true;
256256
}
@@ -497,14 +497,14 @@ boolean drainRegular() {
497497
for (; ; ) {
498498
if (f != null) {
499499
first = null;
500-
ReferenceCountUtil.safeRelease(f);
501500

502501
if (s == Operators.cancelledSubscription()) {
503502
Operators.onNextDropped(f, a.currentContext());
504503
return true;
505504
}
506505

507506
a.onNext(f);
507+
ReferenceCountUtil.safeRelease(f);
508508
f = null;
509509
sent = true;
510510
}

0 commit comments

Comments
 (0)