## Take 只發射前面的N項數據  使用`Take`操作符讓你可以修改Observable的行為，只返回前面的N項數據，然后發射完成通知，忽略剩余的數據。  RxJava將這個操作符實現為`take`函數。 如果你對一個Observable使用`take(n)`（或它的同義詞`limit(n)`）操作符，而那個Observable發射的數據少于N項，那么`take`操作生成的Observable不會拋異常或發射`onError`通知，在完成前它只會發射相同的少量數據。 示例代碼 ```java Observable.just(1, 2, 3, 4, 5, 6, 7, 8) .take(4) .subscribe(new Subscriber<Integer>() { @Override public void onNext(Integer item) { System.out.println("Next: " + item); } @Override public void onError(Throwable error) { System.err.println("Error: " + error.getMessage()); } @Override public void onCompleted() { System.out.println("Sequence complete."); } }); ``` 輸出 ``` Next: 1 Next: 2 Next: 3 Next: 4 Sequence complete. ``` `take(int)`默認不任何特定的調度器上執行。 * Javadoc: [take(int)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#take(int))  `take`的這個變體接受一個時長而不是數量參數。它會丟發射Observable開始的那段時間發射的數據，時長和時間單位通過參數指定。 `take`的這個變體默認在`computation`調度器上執行，但是你可以使用第三個參數指定其它的調度器。 * Javadoc: [take(long,TimeUnit)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#take(long,%20java.util.concurrent.TimeUnit)) * Javadoc: [take(long,TimeUnit,Scheduler)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#take(long,%20java.util.concurrent.TimeUnit,%20rx.Scheduler))