android - 关于RxBus的一个疑问...
本文介绍了android - 关于RxBus的一个疑问...的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
问 题
1 . 先上我写的一个方法:
public static Observable<RxEvent> sendBytesRx(ByteBuffer buffer) {
writeThread.add(buffer);
return RxBus.getDefault().toObserverable(RxEvent.class);
}
这是一个发送数据到服务器的一个函数。
2 . 然后我就调用:
@OnClick(R.id.button2)
public void btn2(Button button) {
BgService.sendBytesRx(CSAPIUtils._1_LogIn(xxx,xxx))
.observeOn(Schedulers.newThread())
.compose(this.bindUntilEvent(ActivityEvent.DESTROY))
.subscribeOn(Schedulers.newThread())
.subscribe(
rxEvent -> {
//解析数据
LogUtils.e(OpenLog,TAG,"1");
},throwable -> {
LogUtils.e(OpenLog,TAG,throwable.getMessage());
});
}
3 . 发现有点不对,
当我多次点击这个Button,触发OnClick方法,发现,
第一次点击,返回数据,打印:1
第二次点击,返回数据,打印:1 1
...
好像是每次点击的时候,就订阅了这个RxBus的事件,但是
事件完成之后却没有去取消订阅...
请教各位大神!刚入Rx大门。
解决方案
多次订阅,每个订阅者都会收到消息。
解决方法:只在onCreate时订阅一次,或者订阅收到消息后取消当前订阅
这篇关于android - 关于RxBus的一个疑问...的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!
查看全文