Hi Team, Any operator in flow to replace this RxJa...

# flow

[Anurag Kumar]

Hi Team,
Any operator in flow to replace this RxJava code -

private val enabled: Observable<Boolean>
enabled.distinctUntilChanged()
    .observeOn(AndroidSchedulers.mainThread())
    .switchMap {
        if (it) showCompletable else hideCompletable
    }
    .doOnDispose(::finalHide)