add error retry

Author: Carson-Ho

app/src/main/java/scut/carson_ho/rxjava_operators/MainActivity.java

@@ -7,8 +7,11 @@
 import io.reactivex.Observable;
 import io.reactivex.ObservableEmitter;
 import io.reactivex.ObservableOnSubscribe;
+import io.reactivex.ObservableSource;
 import io.reactivex.Observer;
+import io.reactivex.annotations.NonNull;
 import io.reactivex.disposables.Disposable;
+import io.reactivex.functions.Function;
 
 
 public class MainActivity extends AppCompatActivity {
@@ -26,14 +29,30 @@ public void subscribe(ObservableEmitter<Integer> e) throws Exception {
                 e.onNext(1);
                 e.onNext(2);
                 e.onError(new Exception("发生错误了"));
-                 }
-               })
-                .onExceptionResumeNext(new Observable<Integer>() {
+                e.onNext(3);
+            }
+        })
+                .retryWhen(new Function<Observable<Throwable>, ObservableSource<?>>() {
                     @Override
-                    protected void subscribeActual(Observer<? super Integer> observer) {
-                        observer.onNext(11);
-                        observer.onNext(22);
-                        observer.onComplete();
+                    public ObservableSource<?> apply(@NonNull Observable<Throwable> throwableObservable) throws Exception {
+
+                        // 返回新的被观察者 Observable
+                        // 此处有两种情况：
+                            // 1. 原始的Observable不重新发送事件：新的被观察者 Observable发送的事件 = Error事件
+                            // 2. 原始的Observable重新发送事件：新的被观察者 Observable发送的事件 = 数据事件
+                        return throwableObservable.flatMap(new Function<Throwable, ObservableSource<?>>() {
+                            @Override
+                            public ObservableSource<?> apply(@NonNull Throwable throwable) throws Exception {
+
+                                // 1. 若返回的Observable发送的事件 = Error事件，则原始的Observable不重新发送事件
+                                // 该异常错误信息可在观察者中的onError（）中获得
+                                 // return Observable.error(new Throwable("retryWhen终止啦"));
+
+                                // 2. 若返回的Observable发送的事件 = 数据事件，则原始的Observable重新发送事件（若持续遇到错误，则持续重试）
+                                  return Observable.just(1);
+                            }
+                        });
+
                     }
                 })
                 .subscribe(new Observer<Integer>() {
@@ -48,7 +67,8 @@ public void onNext(Integer value) {
 
                     @Override
                     public void onError(Throwable e) {
-                        Log.d(TAG, "对Error事件作出响应");
+                        Log.d(TAG, "对Error事件作出响应" + e.toString());
+                        // 获取异常错误信息
                     }
 
                     @Override