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

fix concurrent modification

Browse Source
This commit is contained in:
Maksim Fomenkov
2022-12-13 18:43:04 +03:00
parent 2d621aeef4
commit b0b3819a54
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum_pos/EthereumPosMultiStream.kt
View File

@@ -31,6 +31,7 @@ import org.slf4j.LoggerFactory
import org.springframework.util.ConcurrentReferenceHashMap import org.springframework.util.ConcurrentReferenceHashMap
import reactor.core.publisher.Flux import reactor.core.publisher.Flux
import reactor.core.publisher.Mono import reactor.core.publisher.Mono
import java.util.Collections
@Suppress("UNCHECKED_CAST") @Suppress("UNCHECKED_CAST")
open class EthereumPosMultiStream( open class EthereumPosMultiStream(
@@ -126,7 +127,7 @@ open class EthereumPosMultiStream(
val newHead = MergedHead(heads, PriorityForkChoice(), "ETH Pos Multistream").apply { val newHead = MergedHead(heads, PriorityForkChoice(), "ETH Pos Multistream").apply {
this.start() this.start()
} }
val lagObserver = EthereumPosHeadLagObserver(newHead, upstreams as Collection<Upstream>) val lagObserver = EthereumPosHeadLagObserver(newHead, Collections.unmodifiableCollection(upstreams))
this.lagObserver = lagObserver this.lagObserver = lagObserver
lagObserver.start() lagObserver.start()
newHead newHead