Clients stream should be sequentially concated (#187)

* Clients stream should be sequentially concated * remove debug log
2023-03-28 21:28:22 +04:00
parent bdcb7386cd
commit 8a2455fcd1
2 changed files with 1 additions and 2 deletions
--- a/src/main/kotlin/io/emeraldpay/dshackle/upstream/HeadLagObserver.kt
+++ b/src/main/kotlin/io/emeraldpay/dshackle/upstream/HeadLagObserver.kt
@@ -61,7 +61,6 @@ abstract class HeadLagObserver(
            .sample(throttling)
            .flatMap(this::probeFollowers)
            .map { item ->
-                log.debug("Set to ${item.t2.getId()} lag = ${item.t1}")
                item.t2.setLag(item.t1)
            }
    }
--- a/src/main/kotlin/io/emeraldpay/dshackle/upstream/grpc/GrpcHead.kt
+++ b/src/main/kotlin/io/emeraldpay/dshackle/upstream/grpc/GrpcHead.kt
@@ -76,7 +76,7 @@ class GrpcHead(
                    .repeat()
                    .delayElements(Duration.ofSeconds(1))
            )
-                .flatMap { it.subscribeHead(chainRef) }
+                .concatMap({ it.subscribeHead(chainRef) }, 0)
                .doOnNext {
                    headsCounter.increment()
                }