Observable.zip(
        queryContactsFromLocation(),
        queryContactsForNet(),
        new Func2<List<Contacter>, List<Contacter>, List<Contacter>>() {
            @Override
 
            public List<Contacter> call(List<Contacter> contacters, List<Contacter> contacters2) {
                contacters.addAll(contacters2);
                return contacters;
}
        }
).compose(this.<List<Contacter>>bindToLifecycle())
        .subscribeOn(Schedulers.io
 
())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(new Action1<List<Contacter>>() {
            @Override
            public void call(List<Contacter> contacters) {
                initPage(contacters);
            }
        });

/**
 * 模擬手機本地聯絡人查詢
 */
private Observable<List<Contacter>> queryContactsFromLocation
 
() {
    return Observable.create(new Observable.OnSubscribe<List<Contacter>>() {
        @Override
        public void call(Subscriber<? super List<Contacter>> subscriber) {

            ArrayList<Contacter> contacters = new ArrayList<>();
            contacters.add(new Contacter("location:張三"));
            contacters.add(new Contacter("location:李四"));
            contacters.add(new Contacter("location:王五"));
            subscriber.onNext(contacters);
            subscriber.onCompleted();
        }
    });
}

/**
 * 模擬網路聯絡人列表
 */
private Observable<List<Contacter>> queryContactsForNet() {
    return Observable.create(new Observable.OnSubscribe<List<Contacter>>() {
        @Override
        public void call(Subscriber<? super List<Contacter>> subscriber) {

            try {
                Thread.sleep(3000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }

            ArrayList<Contacter> contacters = new ArrayList<>();
            contacters.add(new Contacter("net:Zeus"));
            contacters.add(new Contacter("net:Athena"));
            contacters.add(new Contacter("net:Prometheus"));
            subscriber.onNext(contacters);
            subscriber.onCompleted();
        }
    });
}

Observable.zip(
        mArticleProtocol.getNewsDetail(params_detail),
        mCommentProtocol.getCommentList(params_comm),
        new Func2<ArticleDetailBean, CommentListBean, List>() {
            @Override
            public List call(ArticleDetailBean articleDetailBean, CommentListBean commentBean) {
                List list = new ArrayList();
                list.add(articleDetailBean);
                list.add(commentBean);
                return list;
                }
            })
        .observeOn(AndroidSchedulers.mainThread())
        .compose(this.<List>bindUntilEvent(ActivityEvent.DESTROY))
        .subscribe(
            new Action1<List>() {
            @Override
            public void call(List list) {
                        initPage(list);
                }
            },
                new Action1<Throwable>() {
                @Override
                public void call(Throwable throwable) {
                        mPageLayout.setPageState(PageStateLayout.STATE_ERROR);
                }
           }
        );