从可观察到的创建BehaviorSubject

Question

假设我有一个Observablea，它从网络获取数据并发出数据，如果我订阅这个observable，每次它试图从网络请求数据时，它会很重。

我想创建BehaviorSubject并将其连接到observableA，这样任何其他线程/对象都将订阅BehaviorSubject以获取最新发出的数据。

到目前为止，我还不能用它来编码。我不能创建空的BehaviorSubject并在observableA内调用，因为它们彼此不相关。我不能订阅observableA并让BehaviorSubject作为observer，你知道我怎么才能做到吗？或者也许更好？

Answer 1

您可以使用多播。例如，

Observable<String> o = ...;
ConnectableObservable<String> co = o.multicast(BehaviorSubject.<String> create());
co.connect();
co.subscribe(...);
co.subscribe(...);
co.subscribe(...);