RxJava Kotlin大json超时管理Android

如何解决RxJava Kotlin大json超时管理Android

我在Android应用程序上有两个调用，当应用程序打开时，该应用程序有两个API调用初始屏幕上的后端，第一个调用通过Postman大约需要10到12秒，另一个需要3到4秒。我首先在后台启动这两个程序是为了优化时间，但这不是一个好主意，因为一旦超时，应用就会崩溃，甚至没有进行充电活动，所以我确实改变了策略，我打了一个电话：

body.subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread())
            .retry(3)
            .timeout(30,TimeUnit.SECONDS)
            .retryWithDelay(3,20).doOnError {
                    throwable ->
                if(throwable is TimeoutException){
                    Log.e("error timeout","Throwable " + throwable.message)
                } else {
                    Log.e("error loading msn","Throwable " + throwable.message)
                }
            }
            .doOnComplete {
                loadplanning(naMetable)
            }
            .timeout<Long,Long>(
                Observable.timer(1,TimeUnit.MINUTES),Function { Observable.timer(1,TimeUnit.MINUTES) }
            )
            .subscribe { result ->
                doAsync {
                    if (result != null && result.programs?.size!! > 0) {
                        App.appDatabase.clearallTables()
                        result.students!!.forEach {
                            App.database.saveStudent(it)
                        }
                    }
                }
            }

就像在调用中一样，只有在学生部分完成后，我才调用将调用第二个端点的函数：

private fun loadplanning(naMetable : Map<String,String>){
        val plannings = App.apiclient.getApiService().getAircraftPlannings(naMetable)
        plannings.subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread())
            .doOnComplete {
                val intent = Intent(this,PreferenceActivity::class.java)
                startActivity(intent)
            }
            .retryWithDelay(3,20)
            .doOnError { throwable -> Log.e("error loading planning","Throwable " + throwable.message) }
            .subscribe {
                doAsync {
                    it.aircraftPlanningEvents?.forEach {
                        App.database.aircraftPlanningToEntity(it)
                    }
                }
            }
    }

问题是使用邮递员需要花费几秒钟的时间，但是从不发送超时错误，但是在应用程序上，它做了很多事情，而且它困扰着我，因为我不知道为什么。我使用重试功能重试以防万一，但是仍然...

fun <T> Observable<T>.retryWithDelay(maxRetries: Int,retryDelayMillis: Int): Observable<T> {
        var retryCount = 0
        return retrywhen { thObservable ->
            thObservable.flatMap { throwable ->
                if (++retryCount < maxRetries) {
                    Observable.timer(retryDelayMillis.toLong(),TimeUnit.SECONDS)
                } else {
                    Observable.error(throwable)
                }
            }
        }
    }

有人遇到过与我相同的问题吗？如果可以帮助我避免这种情况，谢谢。