拿第一個(gè)例子開始，我們安裝的應(yīng)用程序列表按照字母表的順序排序。然而，如果現(xiàn)在我們想按照最近更新日期來排序我們的App時(shí)該怎么辦？RxJava提供了一個(gè)有用的函數(shù)從列表中按照指定的規(guī)則：groupBy()來分組元素。下圖中的例子展示了groupBy()如何將發(fā)射的值根據(jù)他們的形狀來進(jìn)行分組。

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

這個(gè)函數(shù)將源Observable變換成一個(gè)發(fā)射Observables的新的Observable。它們中的每一個(gè)新的Observable都發(fā)射一組指定的數(shù)據(jù)。

為了創(chuàng)建一個(gè)分組了的已安裝應(yīng)用列表，我們?cè)?code>loadList()函數(shù)中引入了一個(gè)新的元素：

Observable<GroupedObservable<String,AppInfo>> groupedItems = Observable.from(apps)
    .groupBy(new Func1<AppInfo,String>(){
        @Override
        public String call(AppInfo appInfo){
            SimpleDateFormat formatter = new SimpleDateFormat("MM/yyyy");
            return formatter.format(new Date(appInfo.getLastUpdateTime()));
        }
    });

現(xiàn)在我們創(chuàng)建了一個(gè)新的Observable，groupedItems，它將會(huì)發(fā)射一個(gè)帶有GroupedObservable的序列。GroupedObservable是一個(gè)特殊的Observable，它源自一個(gè)分組的key。在這個(gè)例子中，key就是String，代表的意思是Month/Year格式化的最近更新日期。

這一點(diǎn)，我們已經(jīng)創(chuàng)建了幾個(gè)發(fā)射AppInfo數(shù)據(jù)的Observable，用來填充我們的列表。我們想保留字母排序和分組排序。我們將創(chuàng)建一個(gè)新的Observable將所有的聯(lián)系起來，像往常一樣然后訂閱它：

Observable.concat(groupedItems)
    .subscribe(new Observer<AppInfo>() {

        @Override
        public void onCompleted() {
            mSwipeRefreshLayout.setRefreshing(false);
        }

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

        @Override
        public void onNext(AppInfo appInfo) {
            mAddedApps.add(appInfo); 
            mAdapter.addApplication(mAddedApps.size() - 1,appInfo);
        }
    });

我們的loadList()函數(shù)完成了，結(jié)果是：

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