我需要在两个活动之间传递一些数据MainActivity and ChildActivity。按钮点击MainActivity应该打开ChildActivity并发送带有数据的事件。我有单例：
Subject<Object, Object> subject = new SerializedSubject<>(PublishSubject.create());
and in MainActivity我有以下按钮单击处理程序：
public void onClick(){
startActivity(new Intent(MainActivity.this, ChildActivity.class));
subject.onNext(new SomeEvent(data));
}
和事件侦听器订阅ChildActivity :
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
addEventListeners();
}
private void addEventListeners() {
subject.ofType(SomeEvent.class)
.observeOn(AndroidSchedulers.mainThread())
.subscribeOn(Schedulers.io()).subscribe(
event -> {
loadData(event.getData());
});
}
当我在开始活动并致电后发送事件时addEventListeners in ChildActivity onCreate仍未订阅此活动并且loadData()不被调用。
使用 RxJava 在活动之间传递数据的正确方法是什么（如果可能的话）？
如果有人需要一个完整的解决方案来使用 RxJava2 在活动之间发送数据
1-创建总线：
public final class RxBus {
private static final BehaviorSubject<Object> behaviorSubject
= BehaviorSubject.create();
public static BehaviorSubject<Object> getSubject() {
return behaviorSubject;
}
}
2- 发件人活动
//the data to be based
MyData data =getMyData();
RxBus.getSubject().onNext(data) ;
startActivity(new Intent(MainActivity.this, AnotherAct.class));
3-接收者活动
disposable = RxBus.getSubject().
subscribeWith(new DisposableObserver<Object>() {
@Override
public void onNext(Object o) {
if (o instanceof MyData) {
Log.d("tag", (MyData)o.getData();
}
}
@Override
public void onError(Throwable e) {
}
@Override
public void onComplete() {
}
});
});
4-取消订阅以避免内存泄漏：
@Override
protected void onDestroy() {
super.onDestroy();
disposable.dispose();
}
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
