android - 在 RxJava2 中将 Listener 转换为 Single

Question

我正在使用 Play 服务 Auth api Phone到目前为止，我已经完成了

  fun startSmsListener() {
    val client = SmsRetriever.getClient(applicationContext /* context */);
    val task = client.startSmsRetriever();
    task.addOnSuccessListener(object : OnSuccessListener<Void> {
        override fun onSuccess(p0: Void?) {
             //do somethin
        }

    })
    task.addOnFailureListener(object : OnFailureListener {
        override fun onFailure(p0: Exception) {
            //Handle error
        }

    })
}

现在我想将其放入 SmsManager 类并将其转换为 Single/Observable，以便我可以在我的 View 模型中以 react 方式处理它。我该怎么做？

到目前为止我得到了这个:

var single = Single.create(SingleOnSubscribe<Void> { e ->
                val task = client.startSmsRetriever()
                task.addOnSuccessListener {
                    e.onSuccess(it)
                }
                task.addOnFailureListener {
                    e.onError(it)
                }
        })

但我不确定这段代码是否正确，我是否缺少某些东西，比如在处理后删除监听器。

有什么帮助吗？

Answer 1

您对“ bool ”值感兴趣 - 连接或未连接，因此您应该使用 Completable 而不是 Single:

Completable.create { emitter -> 
    val client = SmsRetriever.getClient(applicationContext)
    val task = client.startSmsRetriever() 
    task.addOnSuccessListener { emitter.onComplete() } 
    task.addOnFailureListener { emitter.tryOnError(it) }
}