From bf2dfa82b14131740cd0328a42d81ee4d11976fb Mon Sep 17 00:00:00 2001 From: Termina1 Date: Thu, 29 Jun 2023 19:00:42 +0300 Subject: [PATCH] change sample time for subscribe node status to 500ms --- .../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 4c400b35..466f6c06 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.ofSeconds(2)) + .sample(Duration.ofMillis(500)) .map { block -> NodeStatusResponse.newBuilder() .setDescription(