fixed code style

2022-12-20 16:39:26 +03:00
parent a1c234d3bf
commit 214cb4fd8e
1 changed files with 2 additions and 1 deletions
--- 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()