StakeSquid/dshackle
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

problem: miss most of the new blocks

Browse Source
This commit is contained in:
Igor Artamonov
2019-06-10 21:51:03 -04:00
parent e06ce56742
commit 51751741b3
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/kotlin/io/emeraldpay/dshackle/upstream/EthereumRpcHead.kt
View File

@@ -26,20 +26,20 @@ class EthereumRpcHead(
val batch = Batch() val batch = Batch()
val f = batch.add(Commands.eth().blockNumber) val f = batch.add(Commands.eth().blockNumber)
api.execute(batch) api.execute(batch)
Mono.fromCompletionStage(f) Mono.fromCompletionStage(f).timeout(Duration.ofSeconds(5))
} }
.flatMap { .flatMap {
val batch = Batch() val batch = Batch()
val f = batch.add(Commands.eth().getBlock(it)) val f = batch.add(Commands.eth().getBlock(it))
api.execute(batch) api.execute(batch)
Mono.fromCompletionStage(f) Mono.fromCompletionStage(f).timeout(Duration.ofSeconds(5))
} }
.onErrorContinue { err, _ -> .onErrorContinue { err, _ ->
log.warn("RPC error ${err.message}") log.warn("RPC error ${err.message}")
} }
.filter { block -> .filter { block ->
val curr = head.get() val curr = head.get()
curr == null || curr.difficulty < block.difficulty curr == null || curr.totalDifficulty < block.totalDifficulty
} }
.subscribe { block -> .subscribe { block ->
stream.onNext(block) stream.onNext(block)