Leave state as ready on error

abdrasulov · abdrasulov · commit c478a9dec4ac · 2026-02-04T14:10:51.000+06:00
Getting block is a periodical task. Even if it faces error it will run after.
diff --git a/ethereumkit/src/main/java/io/horizontalsystems/ethereumkit/api/core/ApiRpcSyncer.kt b/ethereumkit/src/main/java/io/horizontalsystems/ethereumkit/api/core/ApiRpcSyncer.kt
@@ -95,11 +95,9 @@ class ApiRpcSyncer(
         rpcApiProvider.single(BlockNumberJsonRpc())
                 .subscribeOn(Schedulers.io())
                 .observeOn(Schedulers.io())
-                .subscribe({ lastBlockNumber ->
+                .subscribe { lastBlockNumber ->
                     listener?.didUpdateLastBlockHeight(lastBlockNumber)
-                }, {
-                    state = SyncerState.NotReady(it)
-                }).let {
+                }.let {
                     disposables.add(it)
                 }
     }

Original file line number	Diff line number	Diff line change
`@@ -95,11 +95,9 @@ class ApiRpcSyncer(`
`95`	`95`	`rpcApiProvider.single(BlockNumberJsonRpc())`
`96`	`96`	`.subscribeOn(Schedulers.io())`
`97`	`97`	`.observeOn(Schedulers.io())`
`98`		`- .subscribe({ lastBlockNumber ->`
	`98`	`+ .subscribe { lastBlockNumber ->`
`99`	`99`	`listener?.didUpdateLastBlockHeight(lastBlockNumber)`
`100`		`- }, {`
`101`		`- state = SyncerState.NotReady(it)`
`102`		`- }).let {`
	`100`	`+ }.let {`
`103`	`101`	`disposables.add(it)`
`104`	`102`	`}`
`105`	`103`	`}`