当前位置:网站首页>It is not allowed to subscribe with a(n) xxx multiple times.Please create a fresh instance of xxx
It is not allowed to subscribe with a(n) xxx multiple times.Please create a fresh instance of xxx
2022-08-02 14:06:00 【慢行的骑兵】
- 记录一个关于rxjava的报错问题,原因(可能是原因之一):subscribe方法使用时,将Observer对象非正常的使用了多次。
io.reactivex.exceptions.ProtocolViolationException: It is not allowed to subscribe with a(n) com.x.y.activity.zzzActivity$1 multiple times. Please create a fresh instance of com.x.y.activity.zzzActivity$1 and subscribe that to the target source instead.
一、报错信息如下

二、关键信息
It is not allowed to subscribe with a(n) xxx.QuestionActivity$1 multiple times.
Please create a fresh instance of xxx.QuestionActivity$1 and subscribe that to the target source instead.
- 翻译:不允许使用(一个QuestionActivity$1)多次订阅。请创建一个新的(QuestionActivity$1实例)并将其订阅到目标源。
- 看到这里还是没有立刻找出原因,然后就花了几分钟百度一下,没有找到最直接的答案,然后就去查看报错原因。于是又去看报错代码,发现了同一个RxBaseSubscriber(自己封装的类,实现了DisposableObserver,DisposableObserver继承了Observer)使用了两次。
- 捋一下RxBaseSubscriber被使用两次的原因,在QuestionActivity中需要访问两个接口(这里不考虑架构问题和rxjava的flatMap操作符),串联访问的,在请求第一个接口的时候创建了RxBaseSubscriber对象rxBaseSubscriber1,访问成功继续请求第二个接口,创建了RxBaseSubscriber对象rxBaseSubscriber2,在第二个接口使用subscribe方法时把rxBaseSubscriber1传入进去了导致的问题。
//错误代码
private RxBaseSubscriber mRxBaseSubscriber1;
private RxBaseSubscriber mRxBaseSubscriber2;
private void funcation1() {
mRxBaseSubscriber1 = new RxBaseSubscriber<String>() {
@Override
public void onError(APIException e) {
}
@Override
public void onSuccess(String code) {
funcation2(code);
}
};
RxUtils
.getInstance()
.//略...
.map(new RxFunction<String>())
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(mRxBaseSubscriber1);
}
private void funcation2(String code) {
mRxBaseSubscriber2 = new RxBaseSubscriber<List<JavaBean>>(){
@Override
public void onError(APIException e) {
//吐司
}
@Override
public void onSuccess(List<JavaBean> areaInfos) {
}
};
RxUtils
.getInstance()
.//略...
.map(new RxFunction<List<JavaBean>>())
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(mRxBaseSubscriber1);
//将mRxBaseSubscriber1更改为mRxBaseSubscriber2,则可以修复出现的错误;
}
边栏推荐
猜你喜欢

二进制乘法运算

Caused by: org.gradle.api.internal.plugins.PluginApplicationException: Failed to apply plugin [id ‘c

St. Regis Takeaway Notes - Lecture 05 Getting Started with Redis
![[ROS] (02) Create & compile ROS package Package](/img/c2/5931d5cbade509c6ca34d66a274756.png)
[ROS] (02) Create & compile ROS package Package

二级指针,数组指针,指针数组和函数指针

科创知识年度盛会,中国科创者大会8月6日首场开幕!

verilog学习|《Verilog数字系统设计教程》夏宇闻 第三版思考题答案(第九章)

【c】小游戏---五子棋之井字棋雏形

spark写sql的方式

Using the cloud GPU + pycharm training model to realize automatic background run programs, save training results, the server automatically power off
随机推荐
MongoDB安装流程心得:
liunx下mysql遇到的简单问题
主存储器(一)
什么?都0202年了,你还不会屏幕适配?
DataX 的使用
redis delay queue
重新学习编程day1 【初始c语言】【c语言编写出计算两个数之和的代码】
宝塔搭建PHP自适应懒人网址导航源码实测
浏览器报错数字代表的大概意思
flutter中App签名
C语言日记 7 输入/输出格式控制
字符串的小知识
C语言sizeof和strlen的区别
spark中RDD与DF的关系
MySQL知识总结 (十一) MySql 日志,数据备份,数据恢复
每周招聘|PostgreSQL专家,年薪60+,高能力高薪资
Caused by: org.gradle.api.internal.plugins.PluginApplicationException: Failed to apply plugin [id ‘c
使用flutter小记
spark(standalone,yarn)
原码、补码、反码