當(dāng)我們不需要整個(gè)序列時(shí)，而是只想取開(kāi)頭或結(jié)尾的幾個(gè)元素，我們可以用take()或takeLast()。

Take

如果我們只想要一個(gè)可觀測(cè)序列中的前三個(gè)元素那將會(huì)怎么樣，發(fā)射它們，然后讓Observable完成嗎？take()函數(shù)用整數(shù)N來(lái)作為一個(gè)參數(shù)，從原始的序列中發(fā)射前N個(gè)元素，然后完成：

private void loadList(List<AppInfo> apps) {
    mRecyclerView.setVisibility(View.VISIBLE);
    Observable.from(apps)
            .take(3)
            .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);
                }
            });
}

下圖中展示了發(fā)射數(shù)字的一個(gè)可觀測(cè)序列。我們對(duì)這個(gè)可觀測(cè)序列應(yīng)用take(2)函數(shù)，然后我們創(chuàng)建一個(gè)只發(fā)射可觀測(cè)源的第一個(gè)和第二個(gè)數(shù)據(jù)的新序列。

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

TakeLast

如果我們想要最后N個(gè)元素，我們只需使用takeLast()函數(shù)：

Observable.from(apps)
        .takeLast(3)
        .subscribe(...);

正如聽(tīng)起來(lái)那樣不值一提，值得注意的是因?yàn)閠akeLast()方法只能作用于一組有限的序列（發(fā)射元素），它只能應(yīng)用于一個(gè)完整的序列。

下圖中展示了如何從可觀測(cè)源中發(fā)射最后一個(gè)元素來(lái)創(chuàng)建一個(gè)新的序列：

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

下圖中展示了我們?cè)谝寻惭b的應(yīng)用列表使用take()和takeLast()函數(shù)后發(fā)生的結(jié)果：

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