drafts reconnecting rsocket

Signed-off-by: Oleh Dokuka <[email protected]>
rsocket · Mar 2, 2020 · 321895f · 321895f
1 parent 10456c2
commit 321895f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/rsocket-core/src/main/java/io/rsocket/util/ReconnectingRSocket.java b/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);
       }