Transforming Operator Window RxJava

RxTransformingOperatorWindow.java

public class RxTransformingOperatorWindow {
    public static void main(String[] args) {
        Observable.range(1, 10)
                .window(3)
                .subscribe(longObservable -> {
                            System.out.println("starting new window");
                            longObservable.subscribe(aLong -> System.out.println("window item " + aLong),
                                    throwable -> System.out.println("window error"),
                                    () -> System.out.println("window completed")
                            );
                        }, throwable -> System.out.println("onError"),
                        () -> System.out.println("onCompleted"));
    }
}