From 5fe1c212f40a5592439a3123a863a31c84f3b6bf Mon Sep 17 00:00:00 2001 From: Termina1 Date: Thu, 29 Jun 2023 19:23:11 +0300 Subject: [PATCH] 200ms for heads --- .../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 466f6c06..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(500)) + .sample(Duration.ofMillis(200)) .map { block -> NodeStatusResponse.newBuilder() .setDescription(