问题
观察者模式中，多个监听对象监听蓝牙状态变更 ，通知变更时，用Rxjava异步调用时， 在：
new Consumer<Throwable>() 里抛出异常:
Attempt to invoke virtual method ‘boolean java.lang.String.contains(java.lang.CharSequence)’ on a null object reference：
* 通知监听者：有设备断开，或者连接上
*
* @param bleDevice : 设备地址
* @param connectState ：
*/
@Override
public void notifyConStateObserver(BleDevice bleDevice, int connectState) {
if (disposable != null) disposable = null;
disposable = io.reactivex.Observable.create(new ObservableOnSubscribe<Object>() {
@Override
public void subscribe(ObservableEmitter<Object> emitter) throws Exception {
emitter.onNext(bleDevice);//把数据传到subscribe--accept中， list不能为空
}
}).subscribeOn(AndroidSchedulers.mainThread())
.subscribe(new Consumer<Object>() {
@Override
public void accept(Object o) throws Exception {
//...
}
}
, new Consumer<Throwable>() {
@Override
public void accept(Throwable throwable) throws Exception {
throwable.getStackTrace();
LogUtils.e(throwable.toString());
}
});
}
分析：
一开始以为是监听的对象实例为空，但是调试后发现，有些实例是可以执行，然后看过了一遍所有监听回调的地方。
原因：
与上面的代码无关，与监听的对象回调里，有一个空字符串没有判断，直接使用造成这里抛出异常。
以下是听到的activity代码,在connected方法里的getName(）返回的是null,使用之后先bleDevice.getName().isEmpty（）判断一下再执行里面的操作
private void initBleConnetStatus() {
BleObserver bleObserver = new BleObserver() {
@Override
//...
@Override
public void connected(BleDevice bleDevice) {//连接之后，刷新主页界面
if (!bleDevice.getName().isEmpty() && bleDevice.getName().contains("Yoga")) {
mStepCountButton.setVisibility(View.GONE);
mTempButton.setVisibility(View.VISIBLE);
} else if (bleDevice.getName().contains("Darwin")) {
mTempButton.setVisibility(View.GONE);
mStepCountButton.setVisibility(View.VISIBLE);
}
}
//...
}
};
ObserverManager.getInstance().addObserver(bleObserver);
}版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/101543.html
