veyndan

public class ObservableTest {

    @Test
    public void observable_withRecursion_returnsAllObjects() {
        final int maxPageNum = 15;
        getIntegers(1, 5, maxPageNum)
                .subscribe(System.out::println);
    }

    private Observable<Integer> getIntegers(final int pageStart, final int pageSize, final int maxPageNum) {