Markdium-Chapter 9: Observable's action operators

Markdium-Java.java

    
    /**
     * Using the observableWithErrorSrc skip error and return twice "Buggy Day"
     * @return
     */
    public static Observable getObservableWithOnErrorResumeNext() {
        return observableWithErrorSrc
                .onErrorResumeNext(Observable.just("Buggy day").repeat(2));
    }
    /**
     * OutPut result:
     * value emitted is Monday
     * value emitted is Buggy day
     * value emitted is Buggy day
     * onCompleteCalled
     */
    @Test
    public void testObservableWithOnErrorResumeNext() {
        Answer9_ObservableActions.getObservableWithOnErrorResumeNext()
                .subscribe(it -> System.out.println("value emitted is " + it),
                        Throwable::printStackTrace,
                        () -> System.out.println("onCompleteCalled"));
    }