什么时候不使用 RxJava 的 Observable？

Question

例如，我的应用程序中有一个简单的管理器，我试图在其中保留所有内容reactive：

class AppLockManager {

    private val logger = LoggerFactory.getLogger(javaClass)

    private val rxHelper: RxHelper
    private val securityManager: DiarySecurityManager

    private var locked = false
    private var lastUnlockTime: LocalDateTime? = null

    constructor(rxHelper: RxHelper, securityManager: DiarySecurityManager) {
        this.rxHelper = rxHelper
        this.securityManager = securityManager
    }

    fun shouldLock(): Observable<Boolean> {
        return securityManager.isSecutiryEnabled()
                .doOnNext { logger.debug("isSecurityEnabled: $it") }
                .map { it && !locked && isLockTimerExpired() }
                .doOnNext { logger.debug("shouldLock: $it") }
                .compose(rxHelper.applySchedulers())
    }

    private fun isLockTimerExpired(): Boolean {
        if(lastUnlockTime == null) return true
        val timerExpiredMoment = lastUnlockTime!!.plusSeconds(30)
        val now = LocalDateTime.now().isAfter(timerExpiredMoment)
        val isExpired = LocalDateTime.now().isAfter(timerExpiredMoment)
        logger.debug("timerExpiredMoment: $timerExpiredMoment / now: $now; isExpired: $isExpired")
        return isExpired
    }

    fun setLocked(): Observable<Void> {
        return Observable.create<Void> {
            this.locked = true
            it.onCompleted()
        }.compose(rxHelper.applySchedulers())
    }

    fun setUnlocked(): Observable<Void> {
        return Observable.create<Void> {
            this.locked = false
            lastUnlockTime = LocalDateTime.now()
        }.compose(rxHelper.applySchedulers())
    }

    fun resetLockTimer(): Observable<Void> {
        return Observable.create<Void> {
            lastUnlockTime = LocalDateTime.now()
        }.compose(rxHelper.applySchedulers())
    }

}

这是一个简单的类，当我的应用程序必须被锁定时，它会计算时间并从shouldLock() 发出true。

这是我的使用方法：

fun lockAppIfNeeded() {
    appLockManager.shouldLock()
            .doOnNext { logger.debug("shouldLock: $it") }
            .flatMap { if(it == true) Observable.just(it) else Observable.never() } // flow down only if it == true
            .flatMap { appLockManager.setLocked() } // then lock
            .subscribe(sub({}, Throwable::printStackTrace, { // use onComplete as source Observable is empty
                securityManager.anyPassword().subscribe {
                    if (it) {
                        view.navigateToAskPassword() // anyPassword is true
                    } else {
                        view.navigateToFirstPasswordSetup() // anyPassword is false
                    }
                }
            }))
}

看起来很丑，不是吗？ :)

我只是找不到合适的运算符来将空 Observable(appLockManager.setLocked()) 与 securityManager.anyPassword() wwitch return Observable 结合起来，它会发出一个项目。

这让我相信我不应该将 RxJava 用于像 appLockManager.setLocked() 这样的方法。

我应该在这里使用 Observables 吗？ 专门用于 setLocked()/setUnlocked()/resetLockTimer() 方法，它只更新 AppLockManager 并且根本不返回任何数据。

Answer 1

使用嵌套订阅是不好的代码气味。要在另一个完成后使用另一个Observable，可以concat Observables。

您的代码可以更简单。例如，不要使用这个：

.flatMap { if(it == true) Observable.just(it) else Observable.never() } 

您可以改用filter。

因此删除嵌套订阅 + filter 将导致此代码：

fun lockAppIfNeeded() {
    appLockManager.shouldLock()
                 .doOnNext { logger.debug("shouldLock: $it") }
                 .filter { it } // flow down only if it == true
                 .flatMap { appLockManager.setLocked() } // then lock
                 .ignoreElements() // throw away appLockManager items
                 .concatWith(securityManager.anyPassword())
                 .subscribe {
                       if (it) {
                            view.navigateToAskPassword() // anyPassword is true
                       } else {
                           view.navigateToFirstPasswordSetup() // anyPassword is false
                       }
                })
}

Answer 2

@dwursteisen 提出的另一种解决方案是使用Completable。根据changelog，它刚刚变成了@Beta。

有改进的lockAppIfNeeded()方法：

fun lockAppIfNeeded() {
    appLockManager.shouldLock()
            .doOnNext { logger.debug("shouldLock: $it") }
            .filter { it } // flow down only if it == true
            .toCompletable()
            .concatWith(appLockManager.setLocked()) // then lock
            .andThen(securityManager.anyPassword())
            .subscribe(sub {
                if (it) {
                    view.navigateToAskPassword() // anyPassword is true
                } else {
                    view.navigateToFirstPasswordSetup() // anyPassword is false
                }
            })
}

setLock() 返回Completable：

fun setLocked(): Completable {
    return Completable.fromAction { this.locked = true }
            .compose(rxHelper.applySchedulersToCompletable())
}

另外，shoudlLock() 中的 Observable 可以替换为 Single（Observable 发出一项）。