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

fixed review comments

Browse Source
This commit is contained in:
Maksim Fomenkov
2022-12-20 15:36:20 +03:00
parent 5894501f0c
commit f6c6c8d4ef
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/rpc/SubscribeNodeStatus.kt
View File

@@ -57,14 +57,14 @@ class SubscribeNodeStatus(
) )
// subscribe on head/status updates for just added upstreams // subscribe on head/status updates for just added upstreams
val muliStreamUpdates = Flux.merge( val multiStreamUpdates = Flux.merge(
multistreams.all() multistreams.all()
.map { ms -> .map { ms ->
ms.subscribeAddedUpstreams() ms.subscribeAddedUpstreams()
.distinctUntilChanged { .distinctUntilChanged {
it.getId() it.getId()
} }
.filter { knownUpstreams[it.getId()] != true }.flatMap { .filter { knownUpstreams.getOrDefault(it.getId(), false) }.flatMap {
knownUpstreams[it.getId()] = true knownUpstreams[it.getId()] = true
Flux.concat( Flux.concat(
Mono.just( Mono.just(
@@ -80,7 +80,7 @@ class SubscribeNodeStatus(
} }
) )
Flux.concat(descriptions, Flux.merge(upstreamUpdates, muliStreamUpdates)) Flux.concat(descriptions, Flux.merge(upstreamUpdates, multiStreamUpdates))
} }
private fun subscribeUpstreamUpdates( private fun subscribeUpstreamUpdates(