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

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

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

window(closingSelector)

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

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

Javadoc: window(Func0)

window(windowOpenings, closingSelector)

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

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

Javadoc: window(Observable,Func1)

window(count)

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

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

Javadoc: window(int)

window(count, skip)

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

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

Javadoc: window(int,int)

window(timespan, unit[, scheduler])

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

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

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" />

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

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)在每一個(gè)timeshift時(shí)期內(nèi)都創(chuàng)建一個(gè)新的List,然后用原始Observable發(fā)射的每一項(xiàng)數(shù)據(jù)填充這個(gè)列表（在把這個(gè)List當(dāng)做自己的數(shù)據(jù)發(fā)射前，從創(chuàng)建時(shí)開始，直到過了timespan這么長的時(shí)間）。如果timespan長于timeshift，它發(fā)射的數(shù)據(jù)包將會重疊，因此可能包含重復(fù)的數(shù)據(jù)項(xiàng)。

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

這個(gè)變體的window默認(rèn)在computation調(diào)度器上執(zhí)行它的定時(shí)器。

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

window-backpressure

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

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

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

示例代碼

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

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

你還可以選擇每當(dāng)收到爆發(fā)性O(shè)bservable的N項(xiàng)數(shù)據(jù)時(shí)發(fā)射一個(gè)新的數(shù)據(jù)窗口。