我对此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 {
}
})
);