了解 RxJava 基础知识

Question

我刚刚使用 RxJava 迈出了第一步，利用了 tutorial。我了解Observable 和Subscriber 是什么。但是我在“连接”它们时遇到了问题。我刚刚想到了这样一个任务：一个活动 A 启动一个活动 B。活动 B 有一个按钮，您可以使用该按钮创建一个包含当前日期的Date。另一个按钮发出这个Date 并完成活动B。活动A 订阅发出的Date-Observable 并显示当前日期。 （我知道这通常是通过使用活动结果来完成的）。我有以下问题：

我可以通过这段代码在活动 B 中创建一个 Date-Observable（实例 mDate 的类型为 Date，并在活动 B 的其他位置创建）：

Observable<Date> dateObservable =
            Observable.create(sub -> {
        sub.onNext(mDate);
        sub.onCompleted();
    });

但在活动 A 中，我必须订阅它。但是我没有提到活动 B 中的 Observable。我想过在我的 Application 类中静态创建 Observable，但我还不知道 mDate 的值。我可以在不实现“call()”方法的情况下以某种方式创建某种类型的 Observable（其中调用了 onNext() 和 onCompleted()）吗？那么我已经有了一个可以在我的 Aativity 中订阅的 Observable 实例。然后我可以在 Activity B 中实现“call()”方法？或者还有其他 RxJava 功能可以用来实现我描述的目标吗？

Answer 1

你需要一个叫做ReplaySubject的东西。

在您的自定义 MyApplication 类中：

ReplaySubject<Date> dateSubject = ReplaySubject.create();

在活动 B 中：

ReplaySubject<Date> subject = ((MyApplication)getApplication()).getSubject();
subject.onNext(mDate);
subject.onCompleted();

在活动 A 中：

ReplaySubject<Date> subject = ((MyApplication)getApplication()).getSubject();
subject.subscribe(...);