RXjava合并请求网络

111 19:26:29 MMM层
public class Shouyemodule implements Loginoregster.IShouyemodule {

@Override
public void setData(Observer<Object> observer, int page) {

    Baseurl myserver = HttpUtils.getInstance().myserver();
    Observable<Shouye> shouyeObservable = myserver.shouYe(String.valueOf(page));
    if (page==0){

        Observable<Banner> banner = myserver.banner();

        Observable.merge(shouyeObservable,banner).subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread()).subscribe(observer);

    }else {shouyeObservable.subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(observer);

    }

}

}

/// pppppppppp层
public class Shouyepresenter implements Loginoregster.IShouyepresenter {
public Loginoregster.IShouyemodule iShouyemodule;
public Loginoregster.IShouyeView iShouyeView;

public Shouyepresenter(Loginoregster.IShouyemodule iShouyemodule) {
    this.iShouyemodule = iShouyemodule;
}

@Override
public void mTov(int page) {
    if (iShouyeView != null) {
        iShouyemodule.setData(new Observer<Object>() {
            @Override
            public void onSubscribe(Disposable d) {

            }

            @Override
            public void onNext(Object o) {
                if (o instanceof Shouye) {

                    iShouyeView.showView(((Shouye) o).getData().getDatas());
                }
                if (o instanceof Banner) {
                    iShouyeView.showBanner(((Banner) o).getData());
                }
            }

            @Override
            public void onError(Throwable e) {

            }

            @Override
            public void onComplete() {

            }
        }, page);

    }
}

@Override
public void bind(Loginoregster.IShouyeView view) {
    iShouyeView = view;
}

@Override
public void unbind() {

}

}