drafts reconnecting rsocket

Signed-off-by: Oleh Dokuka <[email protected]>

Author: OlegDokuka

rsocket-core/src/main/java/io/rsocket/util/ReconnectingRSocket.java

@@ -99,8 +99,8 @@ public void onComplete() {
     if (value == null) {
       reconnect();
     } else {
-      value.onClose().subscribe(null, null, () -> resubscribeWhen(ON_CLOSE_EXCEPTION));
       Consumer<RSocket>[] array = SUBSCRIBERS.getAndSet(this, TERMINATED);
+      value.onClose().subscribe(null, null, () -> resubscribeWhen(ON_CLOSE_EXCEPTION));
       for (Consumer<? super RSocket> as : array) {
         as.accept(value);
       }