set lag = 0 in case single upstream in multisream

2023-01-17 20:13:25 +04:00
parent ed82aa373a
commit 1efbba29f3
1 changed files with 3 additions and 2 deletions
--- a/src/main/kotlin/io/emeraldpay/dshackle/upstream/Multistream.kt
+++ b/src/main/kotlin/io/emeraldpay/dshackle/upstream/Multistream.kt
@@ -198,8 +198,9 @@ abstract class Multistream(
            }
            lagObserver?.stop()
            lagObserver = null
-            if (upstreams.size > 1) {
-                lagObserver = makeLagObserver()
+            when {
+                upstreams.size == 1 -> upstreams[0].setLag(0)
+                upstreams.size > 1 -> lagObserver = makeLagObserver()
            }
        }
    }