一、描述

定期将来自原始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给它的观察者们。

二、示意图

window

三、示例代码

window操作符与buffer操作符类似，区别在于buffer操作符产生的结果是一个List缓存，而window操作符产生的结果是一个Observable,订阅者可以对这个结果Observable重新进行订阅处理。

// 完整流程版
Observable.just(1, 2, 3, 4, 5, 6, 7, 8)
    .window(3)
    .subscribe(new Subscriber<Observable<Integer>>() {
        @Override
        public void onCompleted() {
            System.out.println("onCompleted.");
        }

        @Override
        public void onError(Throwable e) {
            System.out.println("onError: " + e.getMessage());
        }

        @Override
        public void onNext(Observable<Integer> integerObservable) {
            integerObservable.subscribe(new Subscriber<Integer>() {
                @Override
                public void onCompleted() {
                    System.out.println("onCompleted(inner).");
                }

                @Override
                public void onError(Throwable e) {
                    System.out.println("onError(inner): " + e.getMessage());
                }

                @Override
                public void onNext(Integer integer) {
                    System.out.println("onNext: " + integer);
                }
            });
        }
    });

// 简化版
Observable.just(1, 2, 3, 4, 5, 6, 7, 8)
    .window(3)
    .subscribe(new Action1<Observable<Integer>>() {
        @Override
        public void call(Observable<Integer> integerObservable) {
            System.out.println("start");

            integerObservable.subscribe(new Action1<Integer>() {
                @Override
                public void call(Integer integer) {
                    System.out.println("onNext: " + integer);
                }
            });
        }
    });

四、运行结果

(完整流程版)
onNext: 1
onNext: 2
onNext: 3
onCompleted(inner).
onNext: 4
onNext: 5
onNext: 6
onCompleted(inner).
onNext: 7
onNext: 8
onCompleted(inner).
onCompleted.

(简化版)
start
onNext: 1
onNext: 2
onNext: 3
start
onNext: 4
onNext: 5
onNext: 6
start
onNext: 7
onNext: 8