From f94b320b79c9585fb1fa4114443ba9bfaed967f5 Mon Sep 17 00:00:00 2001 From: Termina1 Date: Fri, 30 Jun 2023 12:45:54 +0300 Subject: [PATCH] reduce sample rate for chain heihgts --- .../kotlin/io/emeraldpay/dshackle/rpc/SubscribeNodeStatus.kt | 2 +- 1 file changed, 1 insertion(+), 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 470bc2fa..b25ca37c 100644 --- a/src/main/kotlin/io/emeraldpay/dshackle/rpc/SubscribeNodeStatus.kt +++ b/src/main/kotlin/io/emeraldpay/dshackle/rpc/SubscribeNodeStatus.kt @@ -103,7 +103,7 @@ class SubscribeNodeStatus( ): Flux { val heads = upstream.getHead().getFlux() .takeUntilOther(cancel.asFlux()) - .sample(Duration.ofMillis(1000)) + .sample(Duration.ofMillis(200)) .map { block -> NodeStatusResponse.newBuilder() .setDescription(