@Test

public void testWindow() {

final ArrayList<List<Integer>> lists = new ArrayList<List<Integer>>();

Observable.concat(Observable.from(1, 2, 3, 4, 5, 6).window(3).map(new Func1<Observable<Integer>, Observable<List<Integer>>>() {

@Override

public Observable<List<Integer>> call(Observable<Integer> xs) {

return xs.toList();

}

})).toBlockingObservable().forEach(new Action1<List<Integer>>() {

@Override

public void call(List<Integer> xs) {

lists.add(xs);

}

});

assertArrayEquals(lists.get(0).toArray(new Integer[3]), new Integer[] { 1, 2, 3 });

assertArrayEquals(lists.get(1).toArray(new Integer[3]), new Integer[] { 4, 5, 6 });

assertEquals(2, lists.size());

}