Window和Buffer類似，但不是發(fā)射來自原始Observable的數(shù)據包，它發(fā)射的是Observables，這些Observables中的每一個都發(fā)射原始Observable數(shù)據的一個子集，最后發(fā)射一個onCompleted通知。

和Buffer一樣，Window有很多變體，每一種都以自己的方式將原始Observable分解為多個作為結果的Observable，每一個都包含一個映射原始數(shù)據的window。用Window操作符的術語描述就是，當一個窗口打開(when a window "opens")意味著一個新的Observable已經發(fā)射（產生）了，而且這個Observable開始發(fā)射來自原始Observable的數(shù)據；當一個窗口關閉(when a window "closes")意味著發(fā)射(產生)的Observable停止發(fā)射原始Observable的數(shù)據，并且發(fā)射終止通知onCompleted給它的觀察者們。

在RxJava中有許多種Window操作符的變體。

window(closingSelector)

http://wiki.jikexueyuan.com/project/rx-docs/images/operators/window1.png" alt="window1" />

window的這個變體會立即打開它的第一個窗口。每當它觀察到closingSelector返回的Observable發(fā)射了一個對象時，它就關閉當前打開的窗口并立即打開一個新窗口。用這個方法，這種window變體發(fā)射一系列不重疊的窗口，這些窗口的數(shù)據集合與原始Observable發(fā)射的數(shù)據是一一對應的。

Javadoc: window(Func0)

window(windowOpenings, closingSelector)

http://wiki.jikexueyuan.com/project/rx-docs/images/operators/window2.png" alt="window2" />

無論何時，只要window觀察到windowOpenings這個Observable發(fā)射了一個Opening對象，它就打開一個窗口，并且同時調用closingSelector生成一個與那個窗口關聯(lián)的關閉(closing)Observable。當這個關閉(closing)Observable發(fā)射了一個對象時，window操作符就會關閉那個窗口。對這個變體來說，由于當前窗口的關閉和新窗口的打開是由單獨的Observable管理的，它創(chuàng)建的窗口可能會存在重疊（重復某些來自原始Observable的數(shù)據）或間隙（丟棄某些來自原始Observable的數(shù)據）。

Javadoc: window(Observable,Func1)

window(count)

http://wiki.jikexueyuan.com/project/rx-docs/images/operators/window3.png" alt="window3" />

這個window的變體立即打開它的第一個窗口。每當當前窗口發(fā)射了count項數(shù)據，它就關閉當前窗口并打開一個新窗口。如果從原始Observable收到了onError或onCompleted通知它也會關閉當前窗口。這種window變體發(fā)射一系列不重疊的窗口，這些窗口的數(shù)據集合與原始Observable發(fā)射的數(shù)據是一一對應的。

Javadoc: window(int)

window(count, skip)

http://wiki.jikexueyuan.com/project/rx-docs/images/operators/window4.png" alt="window4" />

這個window的變體立即打開它的第一個窗口。原始Observable每發(fā)射skip項數(shù)據它就打開一個新窗口（例如，如果skip等于3，每到第三項數(shù)據，它會打開一耳光新窗口）。每當當前窗口發(fā)射了count項數(shù)據，它就關閉當前窗口并打開一個新窗口。如果從原始Observable收到了onError或onCompleted通知它也會關閉當前窗口。如果skip=count，它的行為與window(source, count)相同；如果skip < count，窗口可會有count - skip 個重疊的數(shù)據；如果skip > count，在兩個窗口之間會有skip - count項數(shù)據被丟棄。

Javadoc: window(int,int)

window(timespan, unit[, scheduler])

http://wiki.jikexueyuan.com/project/rx-docs/images/operators/window5.png" alt="window5" />

這個window的變體立即打開它的第一個窗口。每當過了timespan這么長的時間它就關閉當前窗口并打開一個新窗口（時間單位是unit，可選在調度器scheduler上執(zhí)行）。如果從原始Observable收到了onError或onCompleted通知它也會關閉當前窗口。這種window變體發(fā)射一系列不重疊的窗口，這些窗口的數(shù)據集合與原始Observable發(fā)射的數(shù)據也是一一對應的。

Javadoc: window(long,TimeUnit)
Javadoc: window(long,TimeUnit,Scheduler)

window(timespan, unit, count[, scheduler])

http://wiki.jikexueyuan.com/project/rx-docs/images/operators/window6.png" alt="window6" />

這個window的變體立即打開它的第一個窗口。這個變體是window(count)和window(timespan, unit[, scheduler])的結合，每當過了timespan的時長或者當前窗口收到了count項數(shù)據，它就關閉當前窗口并打開另一個。如果從原始Observable收到了onError或onCompleted通知它也會關閉當前窗口。這種window變體發(fā)射一系列不重疊的窗口，這些窗口的數(shù)據集合與原始Observable發(fā)射的數(shù)據也是一一對應的。

Javadoc: window(long,TimeUnit,int)
Javadoc: window(long,TimeUnit,int,Scheduler)

window(timespan, timeshift, unit[, scheduler])

http://wiki.jikexueyuan.com/project/rx-docs/images/operators/window7.png" alt="window7" />

buffer(timespan,?timeshift,?unit)在每一個timeshift時期內都創(chuàng)建一個新的List,然后用原始Observable發(fā)射的每一項數(shù)據填充這個列表（在把這個List當做自己的數(shù)據發(fā)射前，從創(chuàng)建時開始，直到過了timespan這么長的時間）。如果timespan長于timeshift，它發(fā)射的數(shù)據包將會重疊，因此可能包含重復的數(shù)據項。

這個window的變體立即打開它的第一個窗口。隨后每當過了timeshift的時長就打開一個新窗口（時間單位是unit，可選在調度器scheduler上執(zhí)行），當窗口打開的時長達到timespan，它就關閉當前打開的窗口。如果從原始Observable收到了onError或onCompleted通知它也會關閉當前窗口。窗口的數(shù)據可能重疊也可能有間隙，取決于你設置的timeshift和timespan的值。

這個變體的window默認在computation調度器上執(zhí)行它的定時器。

Javadoc: window(long,long,TimeUnit)
Javadoc: window(long,long,TimeUnit,Scheduler)

window-backpressure

你可以使用Window操作符實現(xiàn)反壓backpressure（意思是，處理這樣一個Observable：它產生數(shù)據的數(shù)據可能比它的觀察者消費數(shù)據的數(shù)據快）。

http://wiki.jikexueyuan.com/project/rx-docs/images/operators/bp.window1.png" alt="bp.window1" />

Window操作符可以將大量的數(shù)據序列縮減為較少的數(shù)據窗口序列，讓它們更容易處理。例如，你可以按固定的時間間隔，定期關閉和發(fā)射來自一個爆發(fā)性Observable的數(shù)據窗口。

示例代碼

Observable<Observable<Integer>> burstyWindowed = bursty.window(500, TimeUnit.MILLISECONDS);

http://wiki.jikexueyuan.com/project/rx-docs/images/operators/bp.window2.png" alt="bp.window2" />

你還可以選擇每當收到爆發(fā)性Observable的N項數(shù)據時發(fā)射一個新的數(shù)據窗口。