diff --git a/src/main/kotlin/io/emeraldpay/dshackle/upstream/LogsOracle.kt b/src/main/kotlin/io/emeraldpay/dshackle/upstream/LogsOracle.kt index 70bf24e3..87774a13 100644 --- a/src/main/kotlin/io/emeraldpay/dshackle/upstream/LogsOracle.kt +++ b/src/main/kotlin/io/emeraldpay/dshackle/upstream/LogsOracle.kt @@ -24,12 +24,15 @@ class LogsOracle( subscription = upstream.getHead().getFlux() .publishOn(scheduler) .doOnError { t -> log.error("Failed to subscribe head for oracle", t) } + .doFinally { log.info("unsubscribe head") } .subscribe { setHeight(it.height) } setUpstream(config.rpc) } fun stop() { + log.info("liboracle closed") + subscription?.dispose() subscription = null diff --git a/src/main/resources/LogsOracle.jar b/src/main/resources/LogsOracle.jar index 55dd95f1..350e09f6 100644 Binary files a/src/main/resources/LogsOracle.jar and b/src/main/resources/LogsOracle.jar differ