## Window 定期將來自原始Observable的數據分解為一個Observable窗口，發射這些窗口，而不是每次發射一項數據  `Window`和`Buffer`類似，但不是發射來自原始Observable的數據包，它發射的是Observables，這些Observables中的每一個都發射原始Observable數據的一個子集，最后發射一個`onCompleted`通知。 和`Buffer`一樣，`Window`有很多變體，每一種都以自己的方式將原始Observable分解為多個作為結果的Observable，每一個都包含一個映射原始數據的`window`。用`Window`操作符的術語描述就是，當一個窗口打開(when a window "opens")意味著一個新的Observable已經發射（產生）了，而且這個Observable開始發射來自原始Observable的數據；當一個窗口關閉(when a window "closes")意味著發射(產生)的Observable停止發射原始Observable的數據，并且發射終止通知`onCompleted`給它的觀察者們。 在RxJava中有許多種`Window`操作符的變體。 ### window(closingSelector)  `window`的這個變體會立即打開它的第一個窗口。每當它觀察到`closingSelector`返回的Observable發射了一個對象時，它就關閉當前打開的窗口并立即打開一個新窗口。用這個方法，這種`window`變體發射一系列不重疊的窗口，這些窗口的數據集合與原始Observable發射的數據是一一對應的。 * Javadoc: [window(Func0)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#window(rx.functions.Func0)) ### window(windowOpenings, closingSelector)  無論何時，只要`window`觀察到`windowOpenings`這個Observable發射了一個`Opening`對象，它就打開一個窗口，并且同時調用`closingSelector`生成一個與那個窗口關聯的關閉(closing)Observable。當這個關閉(closing)Observable發射了一個對象時，`window`操作符就會關閉那個窗口。對這個變體來說，由于當前窗口的關閉和新窗口的打開是由單獨的Observable管理的，它創建的窗口可能會存在重疊（重復某些來自原始Observable的數據）或間隙（丟棄某些來自原始Observable的數據）。 * Javadoc: [window(Observable,Func1)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#window(rx.Observable,%20rx.functions.Func1)) ### window(count)  這個`window`的變體立即打開它的第一個窗口。每當當前窗口發射了`count`項數據，它就關閉當前窗口并打開一個新窗口。如果從原始Observable收到了`onError`或`onCompleted`通知它也會關閉當前窗口。這種`window`變體發射一系列不重疊的窗口，這些窗口的數據集合與原始Observable發射的數據是一一對應的。 * Javadoc: [window(int)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#window(int)) ### window(count, skip)  這個`window`的變體立即打開它的第一個窗口。原始Observable每發射`skip`項數據它就打開一個新窗口（例如，如果`skip`等于3，每到第三項數據，它會打開一耳光新窗口）。每當當前窗口發射了`count`項數據，它就關閉當前窗口并打開一個新窗口。如果從原始Observable收到了`onError`或`onCompleted`通知它也會關閉當前窗口。如果`skip=count`，它的行為與`window(source, count)`相同；如果`skip < count`，窗口可會有`count - skip` 個重疊的數據；如果`skip > count`，在兩個窗口之間會有`skip - count`項數據被丟棄。 * Javadoc: [window(int,int)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#window(int,%20int)) ### window(timespan, unit[, scheduler])  這個`window`的變體立即打開它的第一個窗口。每當過了`timespan`這么長的時間它就關閉當前窗口并打開一個新窗口（時間單位是`unit`，可選在調度器`scheduler`上執行）。如果從原始Observable收到了`onError`或`onCompleted`通知它也會關閉當前窗口。這種`window`變體發射一系列不重疊的窗口，這些窗口的數據集合與原始Observable發射的數據也是一一對應的。 * Javadoc: [window(long,TimeUnit)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#window(long,%20java.util.concurrent.TimeUnit)) * Javadoc: [window(long,TimeUnit,Scheduler)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#window(long,%20java.util.concurrent.TimeUnit,%20rx.Scheduler)) ### window(timespan, unit, count[, scheduler])  這個`window`的變體立即打開它的第一個窗口。這個變體是`window(count)`和`window(timespan, unit[, scheduler])`的結合，每當過了`timespan`的時長或者當前窗口收到了`count`項數據，它就關閉當前窗口并打開另一個。如果從原始Observable收到了`onError`或`onCompleted`通知它也會關閉當前窗口。這種`window`變體發射一系列不重疊的窗口，這些窗口的數據集合與原始Observable發射的數據也是一一對應的。 * Javadoc: [window(long,TimeUnit,int)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#window(long,%20java.util.concurrent.TimeUnit,%20int)) * Javadoc: [window(long,TimeUnit,int,Scheduler)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#window(long,%20java.util.concurrent.TimeUnit,%20int,%20rx.Scheduler)) ### window(timespan, timeshift, unit[, scheduler])  `buffer(timespan,?timeshift,?unit)`在每一個`timeshift`時期內都創建一個新的`List`,然后用原始Observable發射的每一項數據填充這個列表（在把這個`List`當做自己的數據發射前，從創建時開始，直到過了`timespan`這么長的時間）。如果`timespan`長于`timeshift`，它發射的數據包將會重疊，因此可能包含重復的數據項。 這個`window`的變體立即打開它的第一個窗口。隨后每當過了`timeshift`的時長就打開一個新窗口（時間單位是`unit`，可選在調度器`scheduler`上執行），當窗口打開的時長達到`timespan`，它就關閉當前打開的窗口。如果從原始Observable收到了`onError`或`onCompleted`通知它也會關閉當前窗口。窗口的數據可能重疊也可能有間隙，取決于你設置的`timeshift`和`timespan`的值。 這個變體的`window`默認在`computation`調度器上執行它的定時器。 * Javadoc: [window(long,long,TimeUnit)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#window(long,%20long,%20java.util.concurrent.TimeUnit)) * Javadoc: [window(long,long,TimeUnit,Scheduler)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#window(long,%20long,%20java.util.concurrent.TimeUnit,%20rx.Scheduler)) ### window-backpressure 你可以使用`Window`操作符實現反壓`backpressure`（意思是，處理這樣一個Observable：它產生數據的數據可能比它的觀察者消費數據的數據快）。  Window操作符可以將大量的數據序列縮減為較少的數據窗口序列，讓它們更容易處理。例如，你可以按固定的時間間隔，定期關閉和發射來自一個爆發性Observable的數據窗口。 示例代碼 ```java Observable<Observable<Integer>> burstyWindowed = bursty.window(500, TimeUnit.MILLISECONDS); ```  你還可以選擇每當收到爆發性Observable的N項數據時發射一個新的數據窗口。 示例代碼 ```java Observable<Observable<Integer>> burstyWindowed = bursty.window(5); ```