set retry limit - 3 sec

2022-12-02 22:09:05 +04:00
parent 60ba6358ad
commit 8e777a4c58
1 changed files with 1 additions and 1 deletions
--- a/src/main/kotlin/io/emeraldpay/dshackle/upstream/FilteredApis.kt
+++ b/src/main/kotlin/io/emeraldpay/dshackle/upstream/FilteredApis.kt
@@ -171,7 +171,7 @@ class FilteredApis(
                .delaySubscription(waitDuration(r + 1))
        }.let { Flux.concat(it) }

-        var result = Flux.concat(first, second, retries)
+        var result = Flux.concat(first, second, retries).take(Duration.ofSeconds(3))

        if (Global.metricsExtended) {
            var count = 0