在一種新的可能場景中處理多個(gè)數(shù)據(jù)來源時(shí)會(huì)帶來：多從個(gè)Observables接收數(shù)據(jù)，處理它們，然后將它們合并成一個(gè)新的可觀測序列來使用。RxJava有一個(gè)特殊的方法可以完成：zip()合并兩個(gè)或者多個(gè)Observables發(fā)射出的數(shù)據(jù)項(xiàng)，根據(jù)指定的函數(shù)Func*變換它們，并發(fā)射一個(gè)新值。下圖展示了zip()方法如何處理發(fā)射的“numbers”和“l(fā)etters”然后將它們合并一個(gè)新的數(shù)據(jù)項(xiàng)：

http://wiki.jikexueyuan.com/project/rxjava/images/chapter6_4.png" alt="" />

對(duì)于“真實(shí)世界”的例子來說，我們將使用已安裝的應(yīng)用列表和一個(gè)新的動(dòng)態(tài)的Observable來讓例子變得有點(diǎn)有趣味。

Observable<Long> tictoc = Observable.interval(1, TimeUnit.SECONDS);

tictocObservable變量使用interval()函數(shù)每秒生成一個(gè)Long類型的數(shù)據(jù)：雖簡單但有效，正如之前所說的，我們需要一個(gè)Func對(duì)象。因?yàn)樗枰獋鲀蓚€(gè)參數(shù)，所以是Func2:

private AppInfo updateTitle(AppInfoappInfo, Long time) {
    appInfo.setName(time + " " + appInfo.getName());
    return appInfo;
}

現(xiàn)在我們的loadList()函數(shù)變成這樣：

private void loadList(List<AppInfo> apps) {
    mRecyclerView.setVisibility(View.VISIBLE);
    Observable<AppInfo> observableApp = Observable.from(apps);

    Observable<Long> tictoc = Observable.interval(1, TimeUnit.SECONDS);

    Observable.zip(observableApp, tictoc,
    (AppInfo appInfo, Long time) -> updateTitle(appInfo, time))
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(new Observer<AppInfo>() {
        @Override
        public void onCompleted() {
            Toast.makeText(getActivity(), "Here is the list!", Toast.LENGTH_LONG).show();
        }

        @Override
        public void onError(Throwable e) {
            mSwipeRefreshLayout.setRefreshing(false);
            Toast.makeText(getActivity(), "Something went wrong!", Toast.LENGTH_SHORT).show();
        }

        @Override
        public void onNext(AppInfoappInfo) {
            if (mSwipeRefreshLayout.isRefreshing()) {
                mSwipeRefreshLayout.setRefreshing(false);
            } 
            mAddedApps.add(appInfo);
            int position = mAddedApps.size() - 1;
            mAdapter.addApplication(position, appInfo);
            mRecyclerView.smoothScrollToPosition(position);
        }
    });
}

正如你看到的那樣，zip()函數(shù)有三個(gè)參數(shù)：兩個(gè)Observables和一個(gè)Func2。

仔細(xì)一看會(huì)發(fā)現(xiàn)observeOn()函數(shù)。它將在下一章中講解：現(xiàn)在我們可以小試一下。

結(jié)果如下：

http://wiki.jikexueyuan.com/project/rxjava/images/chapter6_5.png" alt="" />