RxJava 如何在旧版本的 mainThread 上观察?我无权访问 AndroidSchedulers.mainThread()
RxJava how to observe on mainThread in older versions? I dont have access to AndroidSchedulers.mainThread()
我正在使用 web3 构建项目。
web3j.ethGetBalance("0x2910543af39aba0cd09dbb2d50200b3e800a63d2", latestBlock)
.observable()
.subscribeOn(rx.schedulers.Schedulers.io())
//This needs to be on the main thread!
//But i only have access to rx.schedulers not AndroidSchedulers.mainThread()
.observeOn(rx.schedulers.Schedulers.io())
.subscribe(block -> {
ethereumTV.setText(block.getBalance() + "");
}, error -> {
error.printStackTrace();
});
但是 web3 使用旧版本的 RxJava,我无法访问 mainThread 来观察它(更新文本视图等)
有什么想法吗?
compile 'io.reactivex:rxandroid:1.2.1' // <-- this is needed
compile 'io.reactivex:rxjava:1.1.6'
那么就可以得到
in 'rx.Observable' cannot be applied to '(io.reactivex.Scheduler)'
在这种情况下
rx.android.AndroidSchedulers.mainThread()
我正在使用 web3 构建项目。
web3j.ethGetBalance("0x2910543af39aba0cd09dbb2d50200b3e800a63d2", latestBlock)
.observable()
.subscribeOn(rx.schedulers.Schedulers.io())
//This needs to be on the main thread!
//But i only have access to rx.schedulers not AndroidSchedulers.mainThread()
.observeOn(rx.schedulers.Schedulers.io())
.subscribe(block -> {
ethereumTV.setText(block.getBalance() + "");
}, error -> {
error.printStackTrace();
});
但是 web3 使用旧版本的 RxJava,我无法访问 mainThread 来观察它(更新文本视图等)
有什么想法吗?
compile 'io.reactivex:rxandroid:1.2.1' // <-- this is needed
compile 'io.reactivex:rxjava:1.1.6'
那么就可以得到
in 'rx.Observable' cannot be applied to '(io.reactivex.Scheduler)'
在这种情况下
rx.android.AndroidSchedulers.mainThread()