Merge pull request #57 from p2p-org/limit_retry_time

set retry limit - 3 sec
2022-12-02 22:29:55 +04:00
parent d1021dcf63 8e777a4c58
commit acaeb0c127
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