1

我知道如果 Observable 发出一条数据，它会重新订阅，如果 Observable 发出 onError 通知，它会将该通知传递给观察者并终止。问题是，如果我发出一个 Obervable.just(1,2)，但它不会被观察者接受。那么它的用途是什么？它只是告诉它重新订阅，我什么数据并不重要发射？

Observable.just(1, "2", 3)
                    .cast(Integer.class)
                    .retryWhen(new Function<Observable<Throwable>, ObservableSource<Integer>>() {
                        @Override
                        public ObservableSource<Integer> apply(Observable<Throwable> throwableObservable) throws Exception {
                            return Observable.just(4,5);
                        }
                    })
                    .subscribe(new Consumer<Integer>() {
                        @Override
                        public void accept(Integer integer) throws Exception {
                            Log.i(TAG, "retryWhen重试数据"+integer);
                        }
                    });

并且日志是
retryWhen重试数据1
retryWhen重试数据1

所以 Observable.just(4,5) 不见了？

4

1 回答 1

1

您可以从文档中查看此示例，以更好地了解 retryWhen 应该如何工作（来源：http ://reactivex.io/RxJava/javadoc/io/reactivex/Observable.html#retryWhen-io.reactivex.functions.Function - ):

  Observable.create((ObservableEmitter<? super String> s) -> {
      System.out.println("subscribing");
      s.onError(new RuntimeException("always fails"));
  }).retryWhen(attempts -> {
      return attempts.zipWith(Observable.range(1, 3), (n, i) -> i).flatMap(i -> {
          System.out.println("delay retry by " + i + " second(s)");
          return Observable.timer(i, TimeUnit.SECONDS);
      });
  }).blockingForEach(System.out::println);

输出是：

 subscribing
 delay retry by 1 second(s)
 subscribing
 delay retry by 2 second(s)
 subscribing
 delay retry by 3 second(s)
 subscribing
于 2018-12-05T09:38:42.473 回答