Merge pull request #544 from rsocket/fix-release

fix release first

Author: OlegDokuka

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

@@ -243,14 +243,14 @@ boolean drainRegular() {
       for (; ; ) {
         if (f != null) {
           first = null;
-          ReferenceCountUtil.safeRelease(f);
 
           if (s == Operators.cancelledSubscription()) {
             Operators.onNextDropped(f, a.currentContext());
             return true;
           }
 
           a.onNext(f);
+          ReferenceCountUtil.safeRelease(f);
           f = null;
           sent = true;
         }
@@ -497,14 +497,14 @@ boolean drainRegular() {
       for (; ; ) {
         if (f != null) {
           first = null;
-          ReferenceCountUtil.safeRelease(f);
 
           if (s == Operators.cancelledSubscription()) {
             Operators.onNextDropped(f, a.currentContext());
             return true;
           }
 
           a.onNext(f);
+          ReferenceCountUtil.safeRelease(f);
           f = null;
           sent = true;
         }