From f58745c984eaeaf593ff8d574dd9de5a99ec374c Mon Sep 17 00:00:00 2001 From: Termina1 Date: Thu, 29 Jun 2023 19:43:31 +0300 Subject: [PATCH] 1000 ms --- .../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 b25ca37c..470bc2fa 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(200)) + .sample(Duration.ofMillis(1000)) .map { block -> NodeStatusResponse.newBuilder() .setDescription(