problem: WS upstream stuck in validation
This commit is contained in:
@@ -54,7 +54,8 @@ open class EthereumUpstreamValidator(
|
|||||||
.timeout(
|
.timeout(
|
||||||
Defaults.timeoutInternal,
|
Defaults.timeoutInternal,
|
||||||
Mono.fromCallable { log.warn("No response for eth_syncing from ${upstream.getId()}") }
|
Mono.fromCallable { log.warn("No response for eth_syncing from ${upstream.getId()}") }
|
||||||
.then(Mono.error(TimeoutException("Validation timeout for Syncing"))))
|
.then(Mono.error(TimeoutException("Validation timeout for Syncing")))
|
||||||
|
)
|
||||||
.flatMap { value ->
|
.flatMap { value ->
|
||||||
if (value.isSyncing) {
|
if (value.isSyncing) {
|
||||||
Mono.just(UpstreamAvailability.SYNCING)
|
Mono.just(UpstreamAvailability.SYNCING)
|
||||||
|
|||||||
Reference in New Issue
Block a user