PublishSubject 调用 observable，它在后台（有时）后忽略调用

大佬教程收集整理的这篇文章主要介绍了PublishSubject 调用 observable，它在后台（有时）后忽略调用，大佬教程大佬觉得挺不错的，现在分享给大家，也给大家做个参考。

如何解决PublishSubject 调用 observable，它在后台（有时）后忽略调用？

开发过程中遇到PublishSubject 调用 observable，它在后台（有时）后忽略调用的问题如何解决？下面主要结合日常开发的经验，给出你关于PublishSubject 调用 observable，它在后台（有时）后忽略调用的解决方法建议，希望对你解决PublishSubject 调用 observable，它在后台（有时）后忽略调用有所启发或帮助；

有时，当我的应用退出后台并打开一个片段，该片段应该从远程 API 获取项目列表时，处理对后端调用的 observable 根本不处理它。@H_674_3@

我有以下视图模型，您在第一个 flatMap 中看到箭头的位置，只是没有处理此调用。没有调用 API，它只是被忽略，并且从不调用 flatMap 后面的 .map：@H_674_3@

easyocr

被忽略的 get stores 调用如下所示：@H_674_3@

class Storeviewmodel(application: Application) : AndroIDviewmodel(application) {

    private val disposables = Compositedisposable()
    private val schedulerProvIDer = Injection.provIDeschedulerProvIDer()
    private val activeLocalDatasource by lazy { ActiveLocalDatasource.geTinstance(application.applicationContext) }
    private val repository by lazy { Injection.provIDeActiveRepository(application) }
    private val userPermissionManager by lazy { UserPermissionManager.geTinstance(application) }
    private val loadMoreStores: PublishSubject<LOCATIOn> = PublishSubject.create()
    private var isCurrentlyLoadingStores = false
    lateinit var updateStoreItem: updateStoreItem

    val state = ObservableFIEld<StoreState<List<StoreItem>>>()

    init {
        disposables += loadMoreStores
            .toFlowable(BACkpressureStrategy.LATEST)
            .flatMap { userLOCATIOn ->
                state.set(StoreState.Loading)
                isCurrentlyLoadingStores = true

                val lastRealLOCATIOn = userPermissionManager.uiModel.lastRealLOCATIOn.get()

                activeLocalDatasource.lastuserLOCATIOn = userLOCATIOn

                repository.getStores( <--<---<----<----- This one seems to be ignore
                    userLOCATIOn = userLOCATIOn,realLOCATIOn = lastRealLOCATIOn,starTingAfter = activeLocalDatasource.storesLastID,categorIEsmap = emptymap())
                    .retrywhenIoExceptionlimit()
                    .retrywhenLocked()
                    .subscribeOn(schedulers.io())
                    .toFlowable(BACkpressureStrategy.bUFFER)
            }
            .observeOn(schedulerProvIDer.io())
            .map {
                val handleResponseStart = System.currentTimeMillis()
                val pair = convertResponsetoStoreItems(it)
                activeLocalDatasource.storesHasMore = pair.first
                activeLocalDatasource.storesLastID = pair.second.lastOrNull()?.ID

                Log.wtf("Parsing","${System.currentTimeMillis() - handleResponseStart}ms")
                pair.second
            }
            .subscribeOn(schedulers.computation())
            .observeOn(schedulerProvIDer.ui())
            .subscribe({
                //DO some stuff
            },{
                //Handle some errors
            })
    }

    fun loadMore() {
        loadMoreStores.onNext(LOCATIOn)
    }

    overrIDe fun onCleared() {
        disposables.clear()
        super.onCleared()
    }
}

重新启动应用程序可以解决问题。我猜当应用程序进入后台时有什么东西坏了，但是当应用程序再次进入前台时我能做些什么来修复它？@H_674_3@

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！@H_674_3@

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。@H_674_3@

小编邮箱:dio#foxmail.com (将#修改为@）@H_674_3@

大佬总结

以上是大佬教程为你收集整理的PublishSubject 调用 observable，它在后台（有时）后忽略调用全部内容，希望文章能够帮你解决PublishSubject 调用 observable，它在后台（有时）后忽略调用所遇到的程序开发问题。

如果觉得大佬教程网站内容还不错，欢迎将大佬教程推荐给程序员好友。

本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ：384754419，请注明来意。