change sample time for subscribe node status to 500ms

2023-06-29 19:00:42 +03:00
parent 6ab04ceafe
commit bf2dfa82b1
1 changed files with 1 additions and 1 deletions
--- 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<NodeStatusResponse> {
        val heads = upstream.getHead().getFlux()
            .takeUntilOther(cancel.asFlux())
-            .sample(Duration.ofSeconds(2))
+            .sample(Duration.ofMillis(500))
            .map { block ->
                NodeStatusResponse.newBuilder()
                    .setDescription(