RX Java 2 Testing

    public static void main(String[] args) throws InterruptedException {
        TestSubscriber<Integer> testSubscriber = TestSubscriber.create(5); // For testing backpressure
        TestObserver<Integer> testObserver = TestObserver.create(); // For testing observable.
        Flowable<Integer> integerFlowable = getListOfStudentsFlowable();
        Observable<Integer> observable = getListOfStudents();
        observable.subscribe(testObserver);
        integerFlowable.subscribe(testSubscriber);
        testObserver.assertValueCount(100);
        testSubscriber.assertValueCount(5);
    }

    public static Observable<Integer> getListOfStudents() {
        return Observable.range(0, 100);
    }

    public static Flowable<Integer> getListOfStudentsFlowable() {
        return Flowable.range(0, 100);
    }