android - RxJava/Android Observable 对状态变化没有反应
问题描述
当我为 Subject 调用 onNext 时,observable 不会接受任何更改,也不会做出适当的反应。
所以我们的产品使用 canBus 将数据从我们的控制器发送到我们的硬件,我们使用 rxJava 来处理数据更改。我们已经让 rxJava 与 UI 完美配合,但是对于我们的新 Alexa 功能,由于某种原因,当我直接调用模型函数来更改值(然后调用 subject.onNext)时,什么也没有发生。我似乎找不到错误。流程如下:
亚历克萨回应:
case "ShowerState":
//TODO figure out shower state alexa case
Log.d(TAG, "Intent: ShowerIntent");
if(action.equals("on")){
Log.d(TAG, "Action: On");
digitalShowerModel.changeShowerStateValue(DigitalShowerModel.DigitalShowerState.ON);
}else if(action.equals("off")){
Log.d(TAG, "Action: Off");
digitalShowerModel.changeShowerStateValue(DigitalShowerModel.DigitalShowerState.OFF);
}
break;
数码花洒型号:
public void changeShowerStateValue(DigitalShowerState digitalShowerState) {
Log.d(TAG, "Change shower state value");
currentShowerState = digitalShowerState;
currentShowerStateSubject.onNext(currentShowerState);
}
观察者流程:
private void initDigitalShowerCanMsgs() {
Observable.combineLatest(
digitalShowerRepository.getShowerStateChanges(),
digitalShowerRepository.getWaterTempChanges(),
digitalShowerRepository.getWaterOutputChanges(),
digitalShowerRepository.getWaterFlowChanges(),
Observable.interval(TIME_BETWEEN_DIGITAL_SHOWER_MSGS, TimeUnit.SECONDS),
new Function5<DigitalShowerModel.DigitalShowerState,
Integer, DigitalShowerModel.WaterOutput,
DigitalShowerModel.WaterFlow, Long, ArrayList<Integer>>() {
@Override
public ArrayList<Integer> apply(DigitalShowerModel.DigitalShowerState digitalShowerState, Integer temp, DigitalShowerModel.WaterOutput waterOutput, DigitalShowerModel.WaterFlow waterFlow, Long aLong) throws Exception {
ArrayList<Integer> dataBytes = new ArrayList<>();
dataBytes.add(digitalShowerState.ordinal());
dataBytes.add(temp);
dataBytes.add(waterOutput.ordinal());
dataBytes.add(waterFlow.ordinal());
return dataBytes;
}
})
.observeOn(Schedulers.io())
.subscribe(new Observer<ArrayList<Integer>>() {
@Override
public void onSubscribe(Disposable d) {
}
@Override
public void onNext(ArrayList<Integer> dataBytes) {
Log.d(TAG, "SHOWER CAN MESSAGE OBSERVER");
FC_Cmd[FlexDefs.CTLESVSTATE].fflxout.execute(dataBytes.get(0), dataBytes.get(1),
dataBytes.get(2), dataBytes.get(3), 0, 0);
}
@Override
public void onError(Throwable e) {
e.printStackTrace();
}
@Override
public void onComplete() {
}
});
数字淋浴存储库:
public Observable<DigitalShowerModel.DigitalShowerState> getShowerStateChanges() {
Log.d(TAG, "Get shower state changes DigitalShowerRepository");
return digitalShowerModel.getCurrentShowerStateSubject();
}
数字淋浴模型(观察者):
public Subject<DigitalShowerState> getCurrentShowerStateSubject() {
Log.d(TAG, "Get shower state value");
return currentShowerStateSubject;
}
我不明白为什么没有处理更改。正在命中日志消息“更改淋浴状态值”。观察者也在观察“淋浴器观察者日志”。我还认为可能是这个观察者也调用 getShowerStateChanges 以某种方式影响它:
数码淋浴屏片段:
Observable.combineLatest(
digitalShowerRepository.getShowerStateChanges(),
digitalShowerRepository.getWaterOutputChanges(), new BiFunction<DigitalShowerModel.DigitalShowerState, DigitalShowerModel.WaterOutput, Pair>() {
@Override
public Pair<DigitalShowerModel.DigitalShowerState, DigitalShowerModel.WaterOutput>
apply(DigitalShowerModel.DigitalShowerState digitalShowerState, DigitalShowerModel.WaterOutput waterOutput) throws Exception {
return new Pair<>(digitalShowerState, waterOutput);
}
})
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Observer<Pair>() {
@Override
public void onSubscribe(Disposable d) {
digitalShowerDisposables.add(d);
}
@Override
public void onNext(Pair pair) {
if(!wasInitiatedByUser) {
rainHeadRdoBtn.setOnTouchListener(null);
showerHeadRdoBtn.setOnTouchListener(null);
wandRdoBtn.setOnTouchListener(null);
showerOptions.setOnCheckedChangeListener(null);
if (pair.first == DigitalShowerModel.DigitalShowerState.ON) {
switch ((DigitalShowerModel.WaterOutput) pair.second) {
case RAINHEAD:
rainHeadRdoBtn.setChecked(true);
break;
case SHOWERHEAD:
showerHeadRdoBtn.setChecked(true);
break;
case WAND:
wandRdoBtn.setChecked(true);
break;
}
} else if (pair.first == DigitalShowerModel.DigitalShowerState.OFF) {
showerOptions.clearCheck();
}
rainHeadRdoBtn.setOnTouchListener(DigitalShowerScreenFragment.this);
showerHeadRdoBtn.setOnTouchListener(DigitalShowerScreenFragment.this);
wandRdoBtn.setOnTouchListener(DigitalShowerScreenFragment.this);
showerOptions.setOnCheckedChangeListener(DigitalShowerScreenFragment.this);
}
wasInitiatedByUser = false;
}
@Override
public void onError(Throwable e) {
e.printStackTrace();
}
@Override
public void onComplete() {
}
});
但这似乎主要是 UI 更改观察者。重要说明:我没有写观察者,但我确实了解除了这个问题之外发生了什么。任何帮助,将不胜感激。
解决方案
所以我忘了把它添加到alexa响应类中,我添加后它就起作用了:
TouchSteamApplication.getApplicationComponent().inject(this);
推荐阅读
- pyparsing - 带有 Optional() 子类的 Pyparsing 语法
- python - 两个轴上的 Bbox 故障
- android - developer.android.com 或任何网站的暗模式?
- wordpress - 重写规则以使用查询字符串简化路径
- c# - C# 拆分 XML InnerText
- html - chrome 和 edge 上的滚动条,但 Internet Explorer 上没有
- assembly - 如何在汇编程序中检查数字是偶数还是奇数
- javascript - 如何将网站上的原始文本保存为所有访问该网站的用户都相同?
- c# - 如何从新窗口中提取数据。WPF MVVM
- variadic-functions - Frama-c:如何用 va_list 和 va_arg 证明可变参数的合理性?