如何解决无法在rxjava3中获得订阅的回调?
我从一种方法中获得3种方法,这些方法进行API调用并将结果返回给订阅用户的函数
fun checkCode(code:String){
validateCoupon(code,Consumer {
it.status?.let { it1 -> Log.e("msg",it1) };
});
}
使用过的rxjava观察器
fun validateCoupon(code:String,readyAction: Consumer<RedeemApiResponse>) {
Observable.fromCallable { return@fromCallable validate(code) }
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.onErrorResumeNext { throwable: Throwable -> Observable.empty() }
.subscribe { result: RedeemApiResponse -> Observable.just(result).subscribe { readyAction} }
}
API调用
fun validate(code:String):RedeemApiResponse{
val redeemApiResponse:RedeemApiResponse()
redeemApiResponse.status="Successs"
// api call
return redeemApiResponse
}
我没有在checkCode方法中得到回调。 我在这里想念什么?
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。