From a0aec9635b548e19de3d020fb6579a618eeb3d70 Mon Sep 17 00:00:00 2001
From: Nikolay G <me@govorov.online>
Date: Thu, 11 Jan 2024 12:11:26 +0000
Subject: [PATCH] Fix threadpoll for liboracle (#386)

---
 src/main/kotlin/io/emeraldpay/dshackle/upstream/LogsOracle.kt | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/main/kotlin/io/emeraldpay/dshackle/upstream/LogsOracle.kt b/src/main/kotlin/io/emeraldpay/dshackle/upstream/LogsOracle.kt
index 889f379b..52b259c4 100644
--- 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)
     }
 }