From 214cb4fd8e7086b93a5aa8c1c5a462f08a26755a Mon Sep 17 00:00:00 2001
From: Maksim Fomenkov <maksim.fomenkov@p2p.org>
Date: Tue, 20 Dec 2022 16:39:26 +0300
Subject: [PATCH] fixed code style

---
 .../kotlin/io/emeraldpay/dshackle/rpc/SubscribeNodeStatus.kt   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/main/kotlin/io/emeraldpay/dshackle/rpc/SubscribeNodeStatus.kt b/src/main/kotlin/io/emeraldpay/dshackle/rpc/SubscribeNodeStatus.kt
index 9967b156..93013e66 100644
--- a/src/main/kotlin/io/emeraldpay/dshackle/rpc/SubscribeNodeStatus.kt
+++ b/src/main/kotlin/io/emeraldpay/dshackle/rpc/SubscribeNodeStatus.kt
@@ -119,10 +119,11 @@ class SubscribeNodeStatus(
 
         val statuses = upstream.observeStatus()
             .distinctUntilChanged()
-            .takeUntil{it == UpstreamAvailability.UNAVAILABLE}
+            .takeUntil { it == UpstreamAvailability.UNAVAILABLE }
             .map {
                 if (it == UpstreamAvailability.UNAVAILABLE) {
                     onUnavailable.accept(upstream.getId())
+                    // cancel head subscription & reconnections when upstream becomes unavailable
                     cancel.tryEmitNext(true)
                 }
                 NodeStatusResponse.newBuilder()