problem: lag is not observed on bitcoin

2020-09-01 17:09:45 -04:00
parent 966ce7d8db
commit 4e16a8c270
5 changed files with 79 additions and 26 deletions
--- a/src/main/kotlin/io/emeraldpay/dshackle/upstream/bitcoin/BitcoinMultistream.kt
+++ b/src/main/kotlin/io/emeraldpay/dshackle/upstream/bitcoin/BitcoinMultistream.kt
@@ -64,8 +64,8 @@ open class BitcoinMultistream(
            val newHead = MergedHead(upstreams.map { it.getHead() }).apply {
                this.start()
            }
-//            val lagObserver = TODO
-//            this.lagObserver = lagObserver
+            val lagObserver = BitcoinHeadLagObserver(newHead, upstreams)
+            this.lagObserver = lagObserver
            newHead
        }
        onHeadUpdated(head)