Fix threadpoll for liboracle (#386)

2024-01-11 12:11:26 +00:00
parent a46d7879ad
commit a0aec9635b
1 changed files with 2 additions and 2 deletions
--- a/src/main/kotlin/io/emeraldpay/dshackle/upstream/LogsOracle.kt
+++ b/src/main/kotlin/io/emeraldpay/dshackle/upstream/LogsOracle.kt
@@ -21,8 +21,8 @@ class LogsOracle(
        db.SetUpstream(config.rpc)

        subscription = upstream.getHead().getFlux()
+            .publishOn(scheduler)
            .doOnError { t -> log.error("Failed to subscribe head for oracle", t) }
-            .subscribeOn(scheduler)
            .subscribe {
                log.info("update liboracle state: height=${it.height}")
                db.UpdateHeight(it.height)
@@ -55,6 +55,6 @@ class LogsOracle(
                }
            }
        }
-            .subscribeOn(scheduler)
+            .publishOn(scheduler)
    }
 }