Fixes subscribing in the DashboardFragment.
This commit is contained in:
@@ -23,6 +23,7 @@ import java.util.List;
|
|||||||
|
|
||||||
import io.reactivex.rxjava3.android.schedulers.AndroidSchedulers;
|
import io.reactivex.rxjava3.android.schedulers.AndroidSchedulers;
|
||||||
import io.reactivex.rxjava3.schedulers.Schedulers;
|
import io.reactivex.rxjava3.schedulers.Schedulers;
|
||||||
|
import io.reactivex.rxjava3.subscribers.DisposableSubscriber;
|
||||||
|
|
||||||
public class DashboardFragment extends MCFragment {
|
public class DashboardFragment extends MCFragment {
|
||||||
private DashboardViewModel mViewModel;
|
private DashboardViewModel mViewModel;
|
||||||
@@ -37,12 +38,24 @@ public class DashboardFragment extends MCFragment {
|
|||||||
|
|
||||||
setupRecyclerView(mHolder.list);
|
setupRecyclerView(mHolder.list);
|
||||||
|
|
||||||
// TODO: subscribe better
|
|
||||||
getMonsterRepository()
|
getMonsterRepository()
|
||||||
.getMonsters()
|
.getMonsters()
|
||||||
.subscribeOn(Schedulers.io())
|
.subscribeOn(Schedulers.io())
|
||||||
.observeOn(AndroidSchedulers.mainThread())
|
.observeOn(AndroidSchedulers.mainThread())
|
||||||
.subscribe(monsters -> mViewModel.setMonsters(monsters));
|
.subscribe(new DisposableSubscriber<List<Monster>>() {
|
||||||
|
@Override
|
||||||
|
public void onNext(List<Monster> monsters) {
|
||||||
|
mViewModel.setMonsters(monsters);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void onError(Throwable t) {
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void onComplete() {
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
return root;
|
return root;
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user