RXJava-使用可流动异步方式

Question

重新编辑：我将使用这个方法的结果来初始化我视图中一些按钮的可见性，理论上公认的答案似乎很好，但是第一个方法的返回值是flowable>而不是flowable。因此，我不能将它作为参数传递给订阅，因为它需要可流动的，但它是可流动的

编辑前的问题

override fun doesExist(): Boolean {
        var doesExist = false
        var subscription : Subscription
        val flowable = Flowable.just(SDK.searchContact("contact"))
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(object : FlowableSubscriber<Flowable<List<Contact>>> {

                    override fun onSubscribe(s: Subscription) {
                        subscription = s
                    }

                    override fun onNext(t: Flowable<List<Contact>>?) {
                        doesExist = true
                    }

                    override fun onComplete() {
                        Log.d("tagtagcomplete", "tagtagcomplete")

                    }

                    override fun onError(e: Throwable?) {
                        Log.d("tagtagerror", "tagtagerror")
                    }


        return doesExist
    }

所以我想做的是，如果我不会从searchContract方法得到任何结果，则返回true，如果得到结果，则返回false。在使用observables时，我可以创建一个订阅对象并调用它的方法，但我不知道如何正确地使用流。

我的困惑是：sdk的方法返回一个可流动的 >> ，但在我看来，我需要检查一个联系人是否只存在一次并停止

现在我的方法不进入onError、onNext或OnComplete。它只是返回doesist

Answer 1

我重新编辑我的答案，以下返回类型是你需要的。

fun doesExist(): Flowable<Single<Boolean>> {
    return Flowable.just(Single.just(SDK.searchContact("contact")).map{ it.isEmpty()})
}