RxAndroid操作员retryWhen被调用但未重新订阅

Question

>

使用改型的API类

class interface TestApi {
  @GET("/path/abc/xyz") 
  fun get(): Single
}

UseCase类

null

fun getResult(): Single {
      return testApi.get()
        .map{ response -> 
            val type = response.type
            when(type){
             null -> throw Exception()
             else -> response
            } 
         }
        .retryWhen{ throwableHandler ->
            throwableHandler.flatMap {
                when(it) {
                   is Exception() -> Flowable.error(it)
                   else -> Flowable.timer(3,TimeUnit.SECONDS)
                 }
            }
        }
        .timeout(60, TimeUnit.SECONDS)
    }
    

null

MainClass.kt

usecase.getResult()
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribeBy(onError = {Log.d(TAG,"Error")},
                     onSuccess = {Log.d(TAG,"Next")})

应用程序运行时:
如果api返回NULL，将调用retryWhen()，然后再次调用api。达到事件not超时，并且api返回not NUL结果->onSuccess被调用。这是RXJava中对retryWhen（）运算符的正确处理。

我的问题:
如果我在mainclass.kt中编写一些测试方法（假装API改造），如下所示：

private fun testPretend(): Single<Animal> {
  return Single.just(Animal)
}

mainclass.kt看起来像：

testPretend()
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribeBy(onError = {Log.d(TAG,"Error")},
                     onSuccess = {Log.d(TAG,"Next")})

因此调用事件retryWhen时，不会再次调用testPretend（）方法。这里的问题是什么？
以及testPrerend（）的单次返回和改型API之间的区别是什么？

Answer 1

不会再次调用testpretend()方法，因为它返回的可观察值是要重新订阅的值。如果希望在重新订阅时再次调用该方法,则需要执行如下操作：

Single.defer( () => testPretend() )
  ...
  .retryWhen( ... )
  ...;

这将在重新订阅时调用testpretend()。