我仍然是这个RxAndroid和Rxjava的新手,我在.subscribeOn(Scheduler.io())
上得到了这个错误
private void fetchData() {
compositeDisposable.add(iPokemonDex.getListPokemon()
.subscribeOn(Scheduler.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Consumer<Pokedex>() {
@Override
public void accept(Pokedex pokedex) throws Exception {
}
})
);
}
它应该是Schedulers.io
与s
。所以你的代码应该是这样的:
compositeDisposable.add(iPokemonDex.getListPokemon()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Consumer<Pokedex>() {
@Override
public void accept(Pokedex pokedex) throws Exception {
}
})
);