如何在生命周期独立类中处置Observable？

Question

我有一个基于ConnectivityManager.NetworkCallback的网络更改通知程序类，我想在网络可用时更新一些字段;

override fun onAvailable(network: Network?) {
    super.onAvailable(network)
val db = StoreDatabase.getInstance(context)
val stores = db.createStores()

val disposable = stores.insertStore(Stores(storeName = "testOnAvailableNetInsertions", status 
= AppConstants.Database.SYNC_FAIL))
        .subscribeOn(Schedulers.io())
        .observeOn(Schedulers.io()).subscribeWith(object : DisposableCompletableObserver() {
            override fun onComplete() {
                 if (!isDisposed)
                dispose()
            }

            override fun onError(e: Throwable) {
                if (!isDisposed)
                    dispose()
            }

        }).dispose()

可以在方法结束时调用dispose，或者我必须在其他地方处理该变量，这是我的Dao;

@Insert(onConflict = OnConflictStrategy.REPLACE)
fun insertStore(stores: Stores): Completable 

Answer 1

请注意，在调用onComplete或onError之后，您无需显式处置订阅。一旦收到任何终止事件，观察员将被取消订阅。所以你可以尝试的一件事是：

super.onAvailable(network)
val db = StoreDatabase.getInstance(context)
val stores = db.createStores()

stores.insertStore(Stores(storeName="testOnAvailableNetInsertions",
        status=AppConstants.Database.SYNC_FAIL))
    .subscribeOn(Schedulers.io())
    .subscribe()

在链的末尾调用.dispose()将立即处理订阅，并且在大多数情况下没有多大意义。它可能只适用于您的情况，因为您的用户在技术上做得不多，但我不确定。此外，.dispose()不会返回任何东西。在Kotlin它将返回一个Unit所以val disposable将只是一个Unit。