diff --git a/src/main/kotlin/io/emeraldpay/dshackle/rpc/SubscribeNodeStatus.kt b/src/main/kotlin/io/emeraldpay/dshackle/rpc/SubscribeNodeStatus.kt index 744be837..318548bb 100644 --- a/src/main/kotlin/io/emeraldpay/dshackle/rpc/SubscribeNodeStatus.kt +++ b/src/main/kotlin/io/emeraldpay/dshackle/rpc/SubscribeNodeStatus.kt @@ -106,11 +106,13 @@ class SubscribeNodeStatus( .setDescription(buildDescription(chain, upstream)) .build() } - val currentState = Mono.just(NodeStatusResponse.newBuilder() - .setNodeId(upstream.getId()) - .setDescription(buildDescription(chain, upstream)) - .setStatus(buildStatus(upstream.getStatus(), upstream.getHead().getCurrentHeight())) - .build()) + val currentState = Mono.just( + NodeStatusResponse.newBuilder() + .setNodeId(upstream.getId()) + .setDescription(buildDescription(chain, upstream)) + .setStatus(buildStatus(upstream.getStatus(), upstream.getHead().getCurrentHeight())) + .build() + ) return Flux.concat(currentState, statuses) }