Markdium-Chapter 9: Observable's action operators

Markdium-Java.java

     /**
     * Using the observableWithErrorSrc skip error items and retry twice
     * @return
     */
    public static Observable getObservableWithOnErrorRetry() {
        //you can also return an empty Observable and then quit the Observable nicely
        return observableWithErrorSrc
                .retry(2);
    }
   
  /**
     * OutPut result:
     * value emitted is Monday
     * value emitted is Monday
     * value emitted is Monday
     exception thrown java.lang.NullPointerException: onNext called with null. Null values are generally not allowed in 2.x operators and sources.
     * java.lang.NullPointerException: onNext called with null. Null values are generally not allowed in 2.x operators and sources.
     */
    @Test
    public void testObservableWithOnErrorRecover() {
        Answer9_ObservableActions.getObservableWithOnErrorRetry()
                .subscribe(it -> System.out.println("value emitted is " + it),
                        th -> {
                            System.out.println("exception thrown " + th);
                            th.printStackTrace();
                        },
                        () -> System.out.println("onCompleteCalled"));
    }