import starter.kit.rx.util.RxUtils;
import static rx.android.schedulers.AndroidSchedulers.mainThread;
import static rx.schedulers.Schedulers.io;
public abstract class ResourcePresenter<T extends Entity> extends RxStarterPresenter<RxStarterRecyclerFragment> {
private static final int RESTARTABLE_ID = 1;
<BUG>private PublishSubject<RxPager> pageRequests = PublishSubject.create();
</BUG>
@SuppressWarnings("Unchecked") @Override protected void onCreate(Bundle savedState) {
super.onCreate(savedState);
restartableReplay(RESTARTABLE_ID, new Func0<Observable<ArrayList<T>>>() {

import starter.kit.rx.util.RxUtils;
import static rx.android.schedulers.AndroidSchedulers.mainThread;
import static rx.schedulers.Schedulers.io;
public abstract class ResourcePresenter<T extends Entity> extends RxStarterPresenter<RxStarterRecyclerFragment> {
private static final int RESTARTABLE_ID = 1;
private PublishSubject<RxRequestKey> pageRequests = PublishSubject.create();
@SuppressWarnings("Unchecked") @Override protected void onCreate(Bundle savedState) {
super.onCreate(savedState);
restartableReplay(RESTARTABLE_ID, new Func0<Observable<ArrayList<T>>>() {
