From 8e777a4c58bf4b321a4ec05338de89e5d69c1702 Mon Sep 17 00:00:00 2001 From: Maksim Fomenkov Date: Fri, 2 Dec 2022 22:09:05 +0400 Subject: [PATCH] set retry limit - 3 sec --- src/main/kotlin/io/emeraldpay/dshackle/upstream/FilteredApis.kt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/kotlin/io/emeraldpay/dshackle/upstream/FilteredApis.kt b/src/main/kotlin/io/emeraldpay/dshackle/upstream/FilteredApis.kt index ab53deed..c9173c78 100644 --- 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